Getting Confluent.Kafka.KafkaException: Broker: Message size too large
I followed multiple links online for sending large message to kafka but still getting this error.
exception:
Confluent.Kafka.KafkaException: Broker: Message size too large
at Confluent.Kafka.Producer.Produce(String topic, Byte[] val, Int32 valOffset, Int32 valLength, Byte[] key, Int32 keyOffset, Int32 keyLength, Nullable1 timestamp, Int32 partition, Boolean blockIfQueueFull, IDeliveryHandler deliveryHandler) at Confluent.Kafka.SerializingProducer2.Produce(String topic, TKey key, TValue val, Nullable1 timestamp, Int32 partition, Boolean blockIfQueueFull, IDeliveryHandler2 deliveryHandler)
at Confluent.Kafka.SerializingProducer2.ProduceAsync(String topic, TKey key, TValue val, IDeliveryHandler2 deliveryHandler)
at Confluent.Kafka.Producer2.ProduceAsync(String topic, TKey key, TValue val, IDeliveryHandler2 deliveryHandler)
Kafka broker settings:
message.max.bytes=10000000
replica.fetch.max.bytes=10485760
fetch.message.max.bytes=10000000
Message size is 1.1 mb
Not sure if i am missing any settings.
Please provide the following information:
Read more here: Source link
