我正在尝试将消息发送到主题中,这是我偶尔得到的错误 .

请提供您认为可以解决此问题的任何建议 . 这是错误的堆栈跟踪:

  • 无法按主题整理邮件,分区由于:从代理[ArrayBuffer(id:0,host:XX.X.XX.XX,port:XX)获取主题[Set(logmessage)]的主题元数据] 2016年失败 - 10-05 21:49:04 - 从代理[ArrayBuffer(id:0,host:host:XX.X.XX.XX,port:XX)获取主题[Set(logmessage)]的主题元数据失败kafka.common . KafkaException:从代理[ArrayBuffer(id:0,host:XX.X.XX.XX,port:XX)获取主题[Set(logmessage)]的主题元数据在kafka.client.ClientUtils $ .fetchTopicMetadata(ClientUtils.scala)失败:72)at kafka.producer.BrokerPartitionInfo.updateInfo(BrokerPartitionInfo.scala:82)at kafka.producer.async.DefaultEventHandler $$ anonfun $ handle $ 2.apply $ mcV $ sp(DefaultEventHandler.scala:78)at kafka.utils . 实用程序$ .swallow(Utils.scala:172)位于kafka.produd.async的kafka.utils.Logging $ class.swallowError(Logging.scala:106)at kafka.utils.Utils $ .swallowError(Utils.scala:45) .defaultEventHandler.handle(DefaultEventHandler.scala:78)at kafka.producer.Producer.send(Producer.s cala:77)at kafka.javaapi.producer.Producer.send(Producer.scala:33)at com.startsmartinc.logger.SSLogger.logMessageBundleBolt(SSLogger.java:222)at com.ssi.parsing.MessageBundle.logEventstoAPI(MessageBundle) .java:414)com.ssi.parsing.MessageBundle.processBundle(MessageBundle.java:113)at com.ssi.parsing.MessageBundle.Parse(MessageBundle.java:42)at com.ssi.threads.WorkerThreads.run( WorkerThreads.java:29)java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)at java.util.concurrent.ThreadPoolExecutor $ Worker.run(ThreadPoolExecutor.java:617)at java.lang.Thread.run (Thread.java:745)由kafka.network.BlockingChannel.send(BlockingChannel.scala:100)发出的kafka.producer.SyncProducer.liftedTree1 $ 1(SyncProducer.scala:73)中的java.nio.channels.ClosedChannelException .producer.SyncProducer.kafka $ producer $ SyncProducer $$ doSend(SyncProducer.scala:72)at kafka.producer.SyncProducer.send(SyncProducer.scala:113)at kafka.client.ClientUtils $ .fetchTopicMetadata( ClientUtils.scala:58)