fix(gcp_pubsub source): Remove Tonic default 4MB decode size limit (#…

…22091) * Remove Tonic default 4MB decode size limit * Changelog entry * Update changelog.d/22090_remove_gcp_pubsub_msg_size_limit.fix.md --------- Co-authored-by: Jesse Szwedko <[email protected]> Co-authored-by: Jesse Szwedko <[email protected]>
vectordotdev · Jan 3, 2025 · 3b90e26 · 3b90e26
1 parent 35845a1
commit 3b90e26
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 1 deletion.
diff --git a/changelog.d/22090_remove_gcp_pubsub_msg_size_limit.fix.md b/changelog.d/22090_remove_gcp_pubsub_msg_size_limit.fix.md
@@ -0,0 +1,3 @@
+The `gcp_pubsub` source no longer has a 4MB message size limit.
+
+authors: sbalmos
diff --git a/src/sources/gcp_pubsub.rs b/src/sources/gcp_pubsub.rs
@@ -479,7 +479,9 @@ impl PubsubSource {
                 }
                 Ok(req)
             },
-        );
+        )
+        // Tonic added a default of 4MB in 0.9. This replaces the old behavior.
+        .max_decoding_message_size(usize::MAX);
 
         let (ack_ids_sender, ack_ids_receiver) = mpsc::channel(ACK_QUEUE_SIZE);
Original file line number	Diff line number	Diff line change
		@@ -0,0 +1,3 @@
		The `gcp_pubsub` source no longer has a 4MB message size limit.

		authors: sbalmos
-Original file line number
+Diff line change
@@ Expand Up / @@ -479,7 +479,9 @@ impl PubsubSource { @@
                     }
                     Ok(req)
                 },
-            );
+            )
+            // Tonic added a default of 4MB in 0.9. This replaces the old behavior.
+            .max_decoding_message_size(usize::MAX);
             let (ack_ids_sender, ack_ids_receiver) = mpsc::channel(ACK_QUEUE_SIZE);
@@ Expand Down @@