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. > > > -- > С уважением, Влад Виниченко. >
