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

Reply via email to