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