生成消息时找不到主题：UNKNOWN_TOPIC_OR_PARTITION
我有一个两节点的Kafka集群(EC2实例），其中每个节点用作单独的代理。当我使用以下命令在leader实例上运行生成器时：
kafka-console-producer.sh --broker-list localhost:9092 --topic test
用kafka-topics.sh列出主题表明主题存在。
主题的说明：
kafka-topics.sh --zookeeper localhost:2181 --describe --topic test
退货
Topic:test PartitionCount:8 ReplicationFactor:1 Configs:
Topic: test Partition: 0 Leader: 1 Replicas: 1 Isr: 1
Topic: test Partition: 1 Leader: 2 Replicas: 2 Isr: 2
Topic: test Partition: 2 Leader: 1 Replicas: 1 Isr: 1
Topic: test Partition: 3 Leader: 2 Replicas: 2 Isr: 2
Topic: test Partition: 4 Leader: 1 Replicas: 1 Isr: 1
Topic: test Partition: 5 Leader: 2 Replicas: 2 Isr: 2
Topic: test Partition: 6 Leader: 1 Replicas: 1 Isr: 1
Topic: test Partition: 7 Leader: 2 Replicas: 2 Isr: 2
listeners=PLAINTEXT://0.0.0.0:9092
advertised.listeners=PLAINTEXT://0.0.0.0:9092
port=9092
host.name=kafka-node1(kafka-node1 for the second host)
advertised.host.name=kafka-node1(kafka-node2 for the second host)
advertised.port=9092
谁能帮忙吗？
共有1个答案
如果您正在获取unknown_topic_or_partition，则将以下属性添加到server.properties文件：
listeners=PLAINTEXT://host.name:port
advertised.listeners=PLAINTEXT://host.name:port
在我的案例中，价值如下：
listeners=PLAINTEXT://localhost:9092
advertised.listeners=PLAINTEXT://localhost:9092
-
从示例中，我看到了下面的代码片段，它运行良好。但问题是：我并不总是需要处理输入流并将其生成到接收器。 如果我有一个应用程序，根据某些事件，我必须只发布到kafka主题，以便下游应用程序可以做出某些决定。这意味着，我实际上没有输入流，但我只知道当我的应用程序中发生某些事情时，我需要向kafka的特定主题发布消息。也就是说，我只需要一个接收器。 我查看了示例，但没有找到符合我要求的任何内容。有没有一种
-
我设置了一个EJB项目，使用JMS将持久性实体对象发送到MDB。我使用JBoss EAP 7，使用Apache ActiveMQ作为消息传递提供程序。我像这样设置ConnectionFactory和队列： 这是我的消息生成器，它接收“Account”实体对象作为参数并将其发送到队列： EntityEnqueueBean。Java语言 MDB从队列接收消息并对其进行处理： java账户 不确定我做错
-
我使用的是Kafka confluent schema registry docker镜像，当我在本地测试它时（使用本地安装的Kafka，这可以按预期工作，但当我尝试将其用于远程Kafka集群时，我遇到了一个错误： < code>{"error_code":40401，" message ":"未找到主题。io . confluent . rest . exceptions . restnotfo
-
我想产生一个Kafka主题的信息。该消息应该具有以下模式： 我知道这是一个json模式，那么如何将json转换成字符串呢？
-
我只是在探索，目前我正在使用One