Apache Kafka：未能更新元数据/java.nio.channels.ClosedChannelException
一个奔跑的动物园管理员和两个奔跑的Kafka。
我可以启动Kafka服务器没有问题，并可以在这两个问题上创建主题。然而，当我试图在一台机器上启动生产者，在另一台机器上启动消费者时，麻烦来了：
论《Kafka制作人》:
kafka-console-producer.sh --broker-list <kafka server 1 aws public dns>:9092,<kafka server 2 aws public dns>:9092 --topic samsa
kafka-console-consumer.sh --zookeeper <zookeeper server ip>:2181 --topic samsa
ERROR Error when sending message to topic samsa with key: null, value: 2 bytes
with error: Failed to update metadata after 60000 ms.
(org.apache.kafka.clients.producer.internals.ErrorLoggingCallback)
WARN Fetching topic metadata with correlation id # for topics [Set(samsa)] from broker [BrokerEndPoint(<broker.id>,<producer's advertised.host.name>,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)
WARN Error while fetching metadata with correlation id # : {samsa=LEADER_NOT_AVAILABLE} (org.apache.kafka.clients.NetworkClient)
共有1个答案
这是一个配置问题。
为了让它运行，必须对config文件进行几项更改：
在每个Kafka服务器上的config/server.properties中：
-
null
-
null
<Public IP> localhost localhost.localdomain
-
问题内容： 有没有一种方法可以使用更多最新数据来更新发送到通道的未读数据？ 我有一个goroutine（生产者），其频道提供了对另一个goroutine（消费者）的进度更新。在某些情况下，进度可以比消费者使用更新消息快得多。 这给我带来了问题，因为我可以： 阻止将数据发送到通道。这意味着，如果使用者读取数据的速度较慢，则进度更新goroutine会完全阻塞-不应这样做。 频道已满时，请勿阻止发送并
-
我的xhtml中有下一个结构 方法searchAnimals（）可以，它返回动物项，但dataTable不刷新，但在java代码（managedBean）中，ArrayList包含这些项。我能做什么？谢谢编辑：我正确地使用了de h:和p:后缀（我想是的），代码是完整代码的一部分，但它是无法正确工作的片段。在第一个面板中，我有一个过滤器控件（按类别、按日期等），命令按钮的功能是调用一个在数据库上执
-
我使用RecycerView使用游标显示sqlite数据库中的数据，当我从数据库中删除一项时，该项将被删除，但我的RecycerView视图不会刷新。 我必须回到我的主要活动，然后数据被刷新。我已经使用了notifyItemRemoved（）和notifyDataSetChanged（）
-
从一个方法call AndUpdateInB（），假设我正在调用B类（@Component）的date（）方法，其中我正在调用myRepository.save（）方法来更新db中的一些数据，并且在相同的功能中我正在执行一些其他调用...然后将响应返回给类A。 所以问题是，当类B方法update（）将响应返回给类A方法callAndUpdateInB（）时，数据在数据库中得到更新。但当我调用myR
-
update问题似乎在于从语句中更新数据源。
-
概述 使用update()方法更新文档。这个方法接收以下参数： 一个方档匹配的过滤器，用于过滤要更新的文档 一个用来执行修改操作的更新文档 一个可选的参数 指定过滤器和指定查询的时候是一样的。update()方法默认只更新单个文档，使用multi可选参数指定更新所有匹配的文档。 不能更新文档的_id字段。 更新指定字段 要改变某个字段的值，MongoDB提供了更新操作，比如$set用来修改值。如果
-
更新数据使用Update方法，Update方法的第一个参数为需要更新的内容，可以为一个结构体指针或者一个Map[string]interface{}类型。当传入的为结构体指针时，只有非空和0的field才会被作为更新的字段。当传入的为Map类型时，key为数据库Column的名字，value为要更新的内容。 Update方法将返回两个参数，第一个为 更新的记录数，需要注意的是 SQLITE 数据库
-
查找并更新 在取出数据后，更改字段内容后更新数据。 $user = UserModel::get(1); $user->user_nickname = '老猫'; $user->user_email = 'genmaowan@163.com'; $user->save(); 直接更新数据 也可以直接带更新条件来更新数据 $user = new UserMode