diff --git a/app/lib/kafka.server.ts b/app/lib/kafka.server.ts
index dcaa60ba0..eb85f2fa5 100644
--- a/app/lib/kafka.server.ts
+++ b/app/lib/kafka.server.ts
@@ -8,10 +8,10 @@
 import { Kafka } from 'gcn-kafka'
 import memoizee from 'memoizee'
 
-import { domain, getEnvOrDie } from './env.server'
+import { domain, getEnvOrDieInProduction } from './env.server'
 
-const client_id = getEnvOrDie('KAFKA_CLIENT_ID')
-const client_secret = getEnvOrDie('KAFKA_CLIENT_SECRET')
+const client_id = getEnvOrDieInProduction('KAFKA_CLIENT_ID') ?? ''
+const client_secret = getEnvOrDieInProduction('KAFKA_CLIENT_SECRET')
 const kafka = new Kafka({
   client_id,
   client_secret,
diff --git a/app/routes/circulars.moderation.$circularId.$requestor.tsx b/app/routes/circulars.moderation.$circularId.$requestor.tsx
index 88a779f47..f5bdf846c 100644
--- a/app/routes/circulars.moderation.$circularId.$requestor.tsx
+++ b/app/routes/circulars.moderation.$circularId.$requestor.tsx
@@ -8,7 +8,7 @@
 import type { SEOHandle } from '@nasa-gcn/remix-seo'
 import type { ActionFunctionArgs, LoaderFunctionArgs } from '@remix-run/node'
 import { Form, redirect, useLoaderData } from '@remix-run/react'
-import { Button, ButtonGroup } from '@trussworks/react-uswds'
+import { Button, ButtonGroup, Checkbox } from '@trussworks/react-uswds'
 import { diffLines, diffWords } from 'diff'
 
 import { getUser } from './_auth/user.server'
@@ -41,11 +41,18 @@ export async function action({
     throw new Response(null, { status: 403 })
   const data = await request.formData()
   const intent = getFormDataString(data, 'intent')
+  const redistribute = getFormDataString(data, 'redistribute') === 'on'
+
   if (!intent || !circularId || !requestor)
     throw new Response(null, { status: 400 })
   switch (intent) {
     case 'approve':
-      await approveChangeRequest(parseFloat(circularId), requestor, user)
+      await approveChangeRequest(
+        parseFloat(circularId),
+        requestor,
+        user,
+        redistribute
+      )
       break
     case 'reject':
       await deleteChangeRequest(parseFloat(circularId), requestor, user)
@@ -100,6 +107,13 @@ export default function () {
       <h3>Body</h3>
       <DiffedContent oldString={circular.body} newString={correction.body} />
       <Form method="POST">
+        <Checkbox
+          id="redistribute"
+          name="redistribute"
+          label="Redistribute new version as an email"
+          labelDescription="Only select this option if the change alters the factual content of the Circular."
+          className="margin-y-1"
+        />
         <ButtonGroup>
           <Button type="submit" name="intent" value="approve">
             Approve
diff --git a/app/routes/circulars/circulars.server.ts b/app/routes/circulars/circulars.server.ts
index e855838de..cbfd44c8c 100644
--- a/app/routes/circulars/circulars.server.ts
+++ b/app/routes/circulars/circulars.server.ts
@@ -34,6 +34,7 @@ import type {
 import { sendEmail } from '~/lib/email.server'
 import { feature, origin } from '~/lib/env.server'
 import { closeZendeskTicket } from '~/lib/zendesk.server'
+import { send } from '~/table-streams/circulars'
 
 // A type with certain keys required.
 type Require<T, K extends keyof T> = Omit<T, K> & Required<Pick<T, K>>
@@ -516,7 +517,8 @@ async function deleteChangeRequestRaw(
 export async function approveChangeRequest(
   circularId: number,
   requestorSub: string,
-  user: User
+  user: User,
+  redistribute: boolean
 ) {
   if (!user?.groups.includes(moderatorGroup))
     throw new Response('User is not in the moderators group', {
@@ -527,17 +529,19 @@ export async function approveChangeRequest(
   const circular = await get(circularId)
   const autoincrementVersion = await getDynamoDBVersionAutoIncrement(circularId)
 
+  const newVersion = {
+    ...circular,
+    body: changeRequest.body,
+    subject: changeRequest.subject,
+    editedBy: `${formatAuthor(user)} on behalf of ${changeRequest.requestor}`,
+    editedOn: Date.now(),
+    format: changeRequest.format,
+    submitter: changeRequest.submitter,
+    createdOn: changeRequest.createdOn ?? circular.createdOn, // This is temporary while there are some requests without this property
+  }
+
   const promises = [
-    autoincrementVersion.put({
-      ...circular,
-      body: changeRequest.body,
-      subject: changeRequest.subject,
-      editedBy: `${formatAuthor(user)} on behalf of ${changeRequest.requestor}`,
-      editedOn: Date.now(),
-      format: changeRequest.format,
-      submitter: changeRequest.submitter,
-      createdOn: changeRequest.createdOn ?? circular.createdOn, // This is temporary while there are some requests without this property
-    }),
+    autoincrementVersion.put(newVersion),
     deleteChangeRequestRaw(circularId, requestorSub),
     sendEmail({
       to: [changeRequest.requestorEmail],
@@ -549,6 +553,8 @@ export async function approveChangeRequest(
     }),
   ]
 
+  if (redistribute) promises.push(send(newVersion))
+
   if (changeRequest.zendeskTicketId)
     promises.push(closeZendeskTicket(changeRequest.zendeskTicketId))
 
diff --git a/app/routes/docs.circulars.corrections/route.mdx b/app/routes/docs.circulars.corrections/route.mdx
index fb7c47f14..7c1c329e3 100644
--- a/app/routes/docs.circulars.corrections/route.mdx
+++ b/app/routes/docs.circulars.corrections/route.mdx
@@ -38,6 +38,10 @@ Anyone with a [peer endorsement](/docs/circulars/submitting#to-request-a-peer-en
 3. The moderator will either immediately approve or reject the request, or contact the original submitter (if different from the request submitter) via email for clarification or concurrence before accepting or rejecting the request.
 4. The requester will receive an email when the ticket is closed.
 
+## Redistribution
+
+Our Kafka producer will always produce a new message whenever a change is made to a circular. We may also redistribute the circular via email. This is up to the discretion of the reviewer, determined by whether or not there is a significant update to anything related to the data in the circular.
+
 ## View the revision history
 
 A version history for revised Circulars is publicly viewable in the archive with the "Versions" dropdown. Information about the revision are added to the Circular header including when it was edited, who requested the edit, and which GCN moderator implemented the edits. The path `https://gcn.nasa.gov/circulars/{circularID}` will always point to the latest version of the Circular.
diff --git a/app/table-streams/circulars/index.ts b/app/table-streams/circulars/index.ts
index 18b139829..cf14e3e43 100644
--- a/app/table-streams/circulars/index.ts
+++ b/app/table-streams/circulars/index.ts
@@ -85,7 +85,7 @@ async function getLegacyEmails() {
   return emails
 }
 
-async function send(circular: Circular) {
+export async function send(circular: Circular) {
   const [emails, legacyEmails] = await Promise.all([
     getEmails(),
     getLegacyEmails(),