Hi Владислав, How do you know "they do not reach the kafka server."?
We need to know your configs on producer and server side so that we can help you. Also, you might be able to turn on TRACE or DEBUG log on producer and server for troubleshooting. If possible, a complete log would be better than this partial exception log. Thank you. Luke On Wed, Sep 1, 2021 at 11:52 PM Владислав Виниченко <akeri...@gmail.com> wrote: > Does anyone knows fix for this? > > ср, 1 сент. 2021 г. в 18:39, Владислав Виниченко <akeri...@gmail.com>: > > > ERROR [kafka-producer-network-thread | producer-2] > > c.o.p.a.s.CalculatorAdapter [CalculatorAdapter.java:285] > > Cannot send outgoingDto with decision id = 46d1-9491-123ce9c7a916 in > > kafka: > > org.springframework.kafka.core.KafkaProducerException: Failed to send; > > nested exception is org.apache.kafka.common.errors.TimeoutException: > > Expiring 1 record(s) for save-request-0:604351 ms has passed since batch > > creation > > at > > > org.springframework.kafka.core.KafkaTemplate.lambda$buildCallback$4(KafkaTemplate.java:602) > > at > > > org.springframework.kafka.core.DefaultKafkaProducerFactory$CloseSafeProducer$1.onCompletion(DefaultKafkaProducerFactory.java:871) > > at > > > org.apache.kafka.clients.producer.KafkaProducer$InterceptorCallback.onCompletion(KafkaProducer.java:1356) > > at > > > org.apache.kafka.clients.producer.internals.ProducerBatch.completeFutureAndFireCallbacks(ProducerBatch.java:231) > > at > > > org.apache.kafka.clients.producer.internals.ProducerBatch.done(ProducerBatch.java:197) > > at > > > org.apache.kafka.clients.producer.internals.Sender.failBatch(Sender.java:676) > > at > > > org.apache.kafka.clients.producer.internals.Sender.sendProducerData(Sender.java:380) > > at > > > org.apache.kafka.clients.producer.internals.Sender.runOnce(Sender.java:323) > > at > > org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:239) > > at java.base/java.lang.Thread.run(Thread.java:834) > > Caused by: org.apache.kafka.common.errors.TimeoutException: > > Expiring 1 record(s) for save-request-0:604351 ms has passed since batch > > creation > > > > I have been fighting with him for the second week. > > Revised a bunch of fix recipes, but none of the recipes helped. > > My program sends messages about 60 kilobytes in size, but they do not > > reach the kafka server. > > The entire java application log is filled with exceptions of this kind. > > > > > > -- > > С уважением, Влад Виниченко. > > >
