fix: make clear that error is configuration issue not server error (#…

…2628) Fixes #1225 Signed-off-by: Mark Hindess <mark.hindess@gmail.com>
IBM · Aug 29, 2023 · dedd86d · dedd86d
1 parent a4eafb4
commit dedd86d
Showing 1 changed file with 4 additions and 2 deletions.
diff --git a/async_producer.go b/async_producer.go
@@ -449,8 +449,10 @@ func (p *asyncProducer) dispatcher() {
 			p.returnError(msg, ConfigurationError("Producing headers requires Kafka at least v0.11"))
 			continue
 		}
-		if msg.ByteSize(version) > p.conf.Producer.MaxMessageBytes {
-			p.returnError(msg, ErrMessageSizeTooLarge)
+
+		size := msg.ByteSize(version)
+		if size > p.conf.Producer.MaxMessageBytes {
+			p.returnError(msg, ConfigurationError(fmt.Sprintf("Attempt to produce message larger than configured Producer.MaxMessageBytes: %d > %d", size, p.conf.Producer.MaxMessageBytes)))
 			continue
 		}