有人知道卡夫卡制作人的挂机修复方法吗？

Question

有没有人能告诉我这个例外。

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

我已经和他打了第二个星期了。修改了一堆修复食谱，但没有一个食谱有帮助。我的程序发送大约60KB大小的消息，但是它们不能到达kafka服务器。整个java应用程序日志充满了这类异常。

Answer 1

我的猜测是，填充批处理大小所需的时间比事务的时间要长，因此不会发送消息。

// example
Properties props = new Properties();
...

pros.put(ProducerConfig.BATCH_SIZE_CONFIG, 60000); // 60kb
...

Producer producer = new KafkaProducer<>(props); 

查看这篇文章。

• Kafka Producer Batch
  • Kafka Producer batch size

• 批处理大小配置
  • http://cloudurable.com/blog/kafka-tutorial-kafka-producer-advanced-java-examples/index.html
  • https://kafka.apache.org/26/javadoc/org/apache/kafka/clients/producer/ProducerConfig.html