I am getting following error in kafka producer. org.apache.kafka.common.KafkaException: Producer closed while allocating memory at
org.apache.kafka.clients.producer.internals.BufferPool.allocate(BufferPool.java:151) ~[kafka-clients-2.5.0.jar:?] at org.apache.kafka.clients.producer.internals.RecordAccumulator.append(RecordAccumulator.java:221) ~[kafka-clients-2.5.0.jar:?] at org.apache.kafka.clients.producer.KafkaProducer.doSend(KafkaProducer.java:941) ~[kafka-clients-2.5.0.jar:?] at org.apache.kafka.clients.producer.KafkaProducer.send(KafkaProducer.java:862) ~[kafka-clients-2.5.0.jar:?] What could be the reason for this error message? Kafka version i am using is 2.5.0
