Kafka Producer 错误:使用 timeoutMillis = 9223372036854775807 ms 关闭 Kafka 生产者

Hes*_*sam 6 java apache-kafka apache-kafka-streams

我的 KafkaStream 应用程序之一出现以下错误:

Closing the Kafka producer with timeoutMillis = 9223372036854775807 ms
Run Code Online (Sandbox Code Playgroud)

这不太可能是权限或连接问题。因为它消耗了一批消息(可能直到最后一条可用消息)然后我Informed to shut down在日志中看到,然后State transition from RUNNING to PENDING_SHUTDOWN. 然后我收到超时错误。这是一个简单的单线程应用程序,代码如下:

Closing the Kafka producer with timeoutMillis = 9223372036854775807 ms
Run Code Online (Sandbox Code Playgroud)

小智 0

INFO KafkaProducer:关闭 Kafka 生产者,超时时间为 9223372036854775807 毫秒。 此消息不会关闭应用程序。需要检查其他问题。