Srinivas Dhruvakumar created KAFKA-4430: -------------------------------------------
Summary: Broker logging Topic and partition to exceptions: [topic,6] -> kafka.common.MessageSizeTooLargeException Key: KAFKA-4430 URL: https://issues.apache.org/jira/browse/KAFKA-4430 Project: Kafka Issue Type: Bug Components: core Affects Versions: 0.9.0.1 Environment: Production Reporter: Srinivas Dhruvakumar Priority: Minor I have a setup as below DC Kafka Mirrormaker AGG Kafka Here is the following settings. I have set the max.message.bytes to 1 M on DC and AGG kafka. Mirrormaker producer batch setting is set to 500 KBytes and max.request.size is set to 1 M Byte and ack -> 0. However on the AGG Kafka I get the following exception Closing connection due to error during produce request with correlation id 414156659 from client id producer-1 with ack=0 KafkaServer.log.3:Topic and partition to exceptions: [topic1,6] -> kafka.common.MessageSizeTooLargeException Is this a bug or why would this happen. Noticed that this happens in the Kafka API class. -- This message was sent by Atlassian JIRA (v6.3.4#6332)