kafka生产者无法按主题、分区整理消息,原因是:正在获取主题的主题元数据[set(logmessage)]

amrnrhlw  于 2021-06-07  发布在  Kafka
关注(0)|答案(0)|浏览(198)

我试图把信息发送到主题中,这里是我时不时遇到的错误。
请提供您认为可以解决此问题的任何建议。以下是错误的堆栈跟踪:
未能按主题、分区整理消息,原因是:正在从代理[arraybuffer(id:0,host:xx.x.xx.xx,port:xx)]失败2016-10-05 21:49:04-正在从代理[arraybuffer(id:0,host:host:xx.x.xx.xx,port:xx]失败的kafka.common.kafkaexception:正在从代理[arraybuffer(id:0,host:xx.x.xx.xx,port:xx]在kafka.client.clientutils$.fetchtopicmetadata(clientutils)失败。scala:72)在kafka.producer.brokerpartitioninfo.updateinfo(brokerpartitioninfo。scala:82)在kafka.producer.async.defaulteventhandler$$anonfun$handle$2.apply$mcv$sp(defaulteventhandler)。scala:78)在kafka.utils.utils$.swallow(utils。scala:172)在kafka.utils.logging$class.snownerror(logging。scala:106)在kafka.utils.utils$.swaknerror(utils。scala:45)在kafka.producer.async.defaulteventhandler.handle(defaulteventhandler。scala:78)在Kafka。制片人。制片人。发送(制片人。scala:77)在kafka.javaapi.producer.producer.send(producer。scala:33)在com.startsmartinc.logger.sslogger.logmessagebundlebolt(sslogger。java:222)在com.ssi.parsing.messagebundle.logeventstoapi(messagebundle。java:414)在com.ssi.parsing.messagebundle.processbundle(messagebundle。java:113)在com.ssi.parsing.messagebundle.parse(messagebundle。java:42)在com.ssi.threads.workerthreads.run(workerthreads。java:29)在java.util.concurrent.threadpoolexecutor.runworker(threadpoolexecutor。java:1142)在java.util.concurrent.threadpoolexecutor$worker.run(threadpoolexecutor。java:617)在java.lang.thread.run(线程。java:745)原因:kafka.network.blockingchannel.send(blockingchannel)处的java.nio.channels.closedchannelexception。scala:100)在Kafka。制作人。同步制作人。提升树1美元(同步制作人。scala:73)在kafka.producer.syncproducer.kafka$producer$syncproducer$$dosend(syncproducer。scala:72)在kafka.producer.syncproducer.send(syncproducer。scala:113)在kafka.client.clientutils$.fetchtopicmetadata(clientutils。scala:58)

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题