Hi Kafka Dev team, I am getting following exception occasionally, and data is lost due to this exception. What could cause this error ? We have prod release coming up with New Kafka API end of this week. So I any help is greatly appreciated.
* java.lang.IllegalStateException: Wrong condition: this shouldn't happen.* at org.apache.kafka.clients.producer.internals.BufferPool.allocate(BufferPool.java:156) at org.apache.kafka.clients.producer.internals.RecordAccumulator.append(RecordAccumulator.java:152) at org.apache.kafka.clients.producer.KafkaProducer.send(KafkaProducer.java:237) ................... at java.util.concurrent.FutureTask.run(FutureTask.java:262) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615) at java.lang.Thread.run(Thread.java:744) Here is Producer Config: bootstrap.servers=[List ] acks=1 buffer.memory=3145728 compression.type=snappy retries=3 batch.size=49152 max.request.size=2097152 send.buffer.bytes=2097152 block.on.buffer.full=true send.buffer.bytes=2097152 linger.ms=2000 Thanks, Bhavesh