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
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
Comments
Post a Comment