Does the Produce() call return the 'message too large' error or does …

…it come from the delivery channel?

internal/common/kafka/kafka.go

@@ -149,6 +149,7 @@ func Produce(producer *kafka.Producer, topic string, value interface{}, key stri
 
 	err = producer.Produce(msg, deliveryChan)
 	if err != nil {
+		fmt.Printf("Produce failed: %v\n", err)
 		return err
 	}