message.max.bytes should be 1048588 not 1 MB https://kafka.apache.org…

…/documentation/#brokerconfigs_message.max.bytes
IBM · Feb 15, 2024 · 1bbaf86 · 1bbaf86
1 parent b6c54b7
commit 1bbaf86
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/config.go b/config.go
@@ -523,7 +523,7 @@ func NewConfig() *Config {
 	c.Metadata.Full = true
 	c.Metadata.AllowAutoTopicCreation = true
 
-	c.Producer.MaxMessageBytes = 1000000
+	c.Producer.MaxMessageBytes = 1048588
 	c.Producer.RequiredAcks = WaitForLocal
 	c.Producer.Timeout = 10 * time.Second
 	c.Producer.Partitioner = NewHashPartitioner