Kafka抛出java.nio.chhannels.ClosedChannelException
当我尝试使用kafka控制台工具（V 0.9.0.1，我认为这使用了旧的消费者API）从托管在ec2中的kafka服务器接收消息时，我遇到了以下异常。我如何克服这一点？
#./Kafka-控制台-消费者. sh -动物园管理员zookeeper1.xx.com:2181-话题我的_话题-从头开始
[2016-04-06 14:34:58,219] WARN Fetching topic metadata with correlation id 0 for topics [Set(MY_TOPIC)] from broker [BrokerEndPoint(1014,kafka3.xx.com,9092)] failed (kafka.client.ClientUtils$)
java.nio.channels.ClosedChannelException
at kafka.network.BlockingChannel.send(BlockingChannel.scala:110)
at kafka.producer.SyncProducer.liftedTree1$1(SyncProducer.scala:75)
at kafka.producer.SyncProducer.kafka$producer$SyncProducer$$doSend(SyncProducer.scala:74)
at kafka.producer.SyncProducer.send(SyncProducer.scala:119)
at kafka.client.ClientUtils$.fetchTopicMetadata(ClientUtils.scala:59)
at kafka.client.ClientUtils$.fetchTopicMetadata(ClientUtils.scala:94)
at kafka.consumer.ConsumerFetcherManager$LeaderFinderThread.doWork(ConsumerFetcherManager.scala:66)
at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:63)
[2016-04-06 14:34:58,222] WARN Fetching topic metadata with correlation id 0 for topics [Set(MY_TOPIC)] from broker [BrokerEndPoint(1013,kafka22.xx.com,9092)] failed (kafka.client.ClientUtils$)
java.nio.channels.ClosedChannelException
at kafka.network.BlockingChannel.send(BlockingChannel.scala:110)
at kafka.producer.SyncProducer.liftedTree1$1(SyncProducer.scala:75)
at kafka.producer.SyncProducer.kafka$producer$SyncProducer$$doSend(SyncProducer.scala:74)
at kafka.producer.SyncProducer.send(SyncProducer.scala:119)
at kafka.client.ClientUtils$.fetchTopicMetadata(ClientUtils.scala:59)
at kafka.client.ClientUtils$.fetchTopicMetadata(ClientUtils.scala:94)
at kafka.consumer.ConsumerFetcherManager$LeaderFinderThread.doWork(ConsumerFetcherManager.scala:66)
at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:63)
[2016-
共有3个答案
这实际上是一个警告-没什么大不了的。可能您的主题已损坏？尝试重新创建主题。
我可以通过将< code > advertised . host . name 设置到配置文件来解决这个问题
最初关闭通道异常的原因是，我遇到了一些DNS问题，我通过编辑本地主机文件解决了这个问题
-
当我将enable.auto.commit设置为false并尝试使用基于注释的spring-kafka@kafkalistener手动提交偏移量时，我会得到一个org.springframework.kafka.Listener.listenerExecutionFailedException：无法用传入消息调用侦听器方法 我有一个非常简单的代码如下： 并且当我从生产者发送消息时,我得到以下异常：
-
Spring Boot:2.0.3.发布 kafka.kafka-streams:1.0.0 这看起来像是版本不匹配，但我不清楚我应该对我做什么。
-
我想使用spring-kafka KafkaTemplate, 我创建了一个KafkaConfig类: …并在我写给Kafka的类中自动连接了Kafka模板： 出于某种原因，自动布线似乎不起作用。我注意到当我在debug中运行时，KafkaTemplate为null: 此对象不应为空；它应该是一个KafkaTemplate对象。这将引发空指针异常: kafka-spring过去为我工作得很好
-
我是Kafka的新手，在尝试一个示例场景时，Kafka生产者以JSON格式向消费者发送用户详细信息。我访问过类似的问题，但我无法得到我需要的答案。 如果我在终端中运行任何一个生产者或消费者，在spring boot中运行另一个生产者或消费者，我不会面临任何问题。错误发生在无限循环中（当生产者和消费者都从不同的spring boot项目启动时）： 我在下面提到了消费者配置中的反序列化和受信任包： 我
-
抛出异常的行为是否可能抛出不同的异常？ 为了抛出异常，必须（可选地）分配新对象，并调用其构造函数（隐式调用fillinstacktrace）。在某些情况下，听起来像addSupressed也被称为。那么如果没有足够的内存会发生什么呢？JVM是否需要预分配内置异常？例如，(1/0)会抛出OutOfMemoryError而不是ArithmeticException吗？ 此外，构造函数是一个方法调用，因
-
问题内容： 我正在使用“ mvn install”编译一个开源项目，但最终结果为。我尝试执行，但输出为Java摘要，指示这是无效命令。 我正在使用，为什么会发生这种情况？ 谢谢， 问题答案： 设置环境变量：