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.


-- 
С уважением, Влад Виниченко.

Reply via email to