Kafka无效的主题例外为每个主题！为什么？
kafka-topics --create --bootstrap-server localhost:9092 --replication-factor 1 --partitions 1 --topic distance2
kafka-console-consumer --bootstrap-server localhost:9092 --topic distance2 --from-beginning
[2020-06-01 08:00:27,746]警告[Consumer Clientid=Consumer-Console-Consumer-56224-1,GroupID=Console-Consumer-56224]提取相关id为2的元数据时出错：{Distance2 =Invalid_Topic_Exception}（org.apache.kafka.clients.NetworkClient)[2020-06-01 08:00:27,747]错误[Consumer Clientid=Consumer-Console-Consumer-56224-1,GroupID=Console-Consumer-56224]元数据响应报告无效主题[Distance2 ]（org.apache.kafka.clients.metadata）[2020-06-01 08:00:27,748]错误处理错误消息，终止使用者进程：(kafka.tools.ConsoleConsumer$)
org.apache.kafka.common.errors.InvalidTopicException: Invalid topics: [distance2 ]
Processed a total of 0 messages
作为一个主要问题，似乎应该提供某物无效的理由。我怎么找原因？
共有1个答案
-
在构建Kafka Streams拓扑时，可以通过两种不同的方式对多个主题的读取进行建模： 读取具有相同源节点的所有主题。 选项1相对于选项2是否有相对优势，反之亦然？所有主题都包含相同类型的数据，并具有相同的数据处理逻辑。
-
我们有一个传入的kafka主题，多个基于Avro模式的消息序列化到其中。 我们需要将Avro格式的消息拆分为多个其他kafka主题，基于某个公共模式属性的值。 想了解如何实现它，同时避免在汇流平台上构建中间客户端来进行这种拆分/路由。
-
当我运行这个命令时，我得到2个主题。我知道我创建了测试主题，但我看到了一个名为“__consumer_offsets”的附加主题。从名称来看，它暗示它与消费者补偿有关，但它是如何使用的呢？ 这在Kafka 1.1.0中发生，以及为什么有50个分区。也在寻找一种方法来禁用它，因为每次我尝试运行“description”主题时，它首先打印__consumer_offsets的50个分区，然后打印我的主
-
配置的application.yaml如下所示。这个想法是我有3个输入和3个输出主题。该组件从input topic获取输入，并将输出提供给OutputTopic。 引发的异常为 谁能帮助我与Kafka Streams Spring-Kafka代码样本处理与多个输入和输出主题。 更新：2021年1月21日
-
我一直在寻找了解这 3 个： 主题 行为主体 重播主题 我想使用它们，并知道何时、为什么使用它们，使用它们有什么好处，尽管我已经阅读了文档、观看了教程并搜索了谷歌，但我对此没有任何理解。 那么他们的目的是什么？一个真实的案例将是最受欢迎的，它甚至不需要编写代码。 我更喜欢一个干净的解释，而不仅仅是“a b = 非常感谢。
-
我正在运行ansible在一台服务器上安装Kafka。（在Dev env上，独立设置）但我的剧本在列出Kafka主题的任务列表时失败了。下面是日志。 Journal alctl-fu动物园管理员 /opt/kafka/kafka\u 2.12-2.2.2/config/zookeeper。属性 动物园管理员。服务