org.apache.kafka.clients.producer.internals.RecordBatch.maybeExpire(RecordBatch.java:155) at org.apache.kafka.clients.producer.internals.Sender.run(Sender.
org.apache.kafka.clients.producer.internals.RecordBatch.maybeExpire(RecordBatch.java:136) at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java
org.apache.kafka.clients.producer.internals.ProducerBatch.tryAppend(ProducerBatch.java:106) at org.apache.kafka.clients.producer.KafkaProducer.doSend(KafkaProducer.java
org.apache.kafka.clients.producer.internals.RecordBatch.maybeExpire(RecordBatch.java:160) at org.apache.kafka.clients.producer.internals.Sender.run(Sende
org.apache.kafka.clients.producer.internals.ProducerBatch.tryAppend(ProducerBatch.java:107) at org.apache.kafka.clients.producer.KafkaProducer.doSend(KafkaProducer.ja
org.apache.kafka.clients.producer.internals.RecordBatch.maybeExpire(RecordBatch.java:160) at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java