使用spring kafka 本地调试循环发送1W+消息时，会出现producer超时被强制关闭异常修订版本明细

源

采纳

编辑于 4年前

Think丶

使用spring kafka 本地调试循环发送1W+消息时，会出现producer超时被强制关闭异常

kafka

请教个问题，使用spring kafka 本地调试循环发送1W+消息时，就会会出现producer超时被强制关闭异常，但是部署到服务器循环发送10W+消息都不会出现这种异常，两者使用一样的producer 配置，能帮忙分析下是什么原因吗？

 java.lang.IllegalStateException: Producer is closed forcefully.
    at org.apache.kafka.clients.producer.internals.RecordAccumulator.abortBatches(RecordAccumulator.java:696) [kafka-clients-1.0.1.jar:na]
    at org.apache.kafka.clients.producer.internals.RecordAccumulator.abortIncompleteBatches(RecordAccumulator.java:683) [kafka-clients-1.0.1.jar:na]
    at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:185) [kafka-clients-1.0.1.jar:na]
    at java.lang.Thread.run(Thread.java:748) [na:1.8.0_144]

预览