使用--bootstrap-server创建Kafka主题给出超时异常（Kafka版本2.5）
当尝试使用--bootstrap-server创建主题时，我得到异常“执行Kafka主题命令时出错：等待节点时超时”：-
kafka-topics --bootstrap-server localhost:9092 --topic boottopic --replication-factor 3 --partitions
然而，以下操作很好，使用--zookeeper：-
kafka-topics --zookeeper localhost:2181--topic boottopic --replication-factor 3 --partitions
注意-我设置了Zookeeper仲裁和Kafka broker集群，每个集群在一台机器上包含3个实例（用于开发）
共有1个答案
老问题，但我会回答无论如何，为了互联网的智慧。您可能设置了身份验证，当使用--bootstrap-server时，还需要使用--command-config指定您的凭据
-
使用命令时： /usr/local/kafka/bin/kafka-topics.sh--创建--zookeeper localhost:2181--复制-因子1--分区1--主题测试 提前道谢。
-
我正在编程一个客户端工作与Kafka0.9。我想知道如何制造话题。这个答案：如何通过Java在Kafka中创建一个主题，与我所问的类似。除此之外，该解决方案仅适用于Kafka 0.8.2，这与Kafka 0.9的API有很大不同。
-
null camel-kafka中是否有任何配置，我们可以使用它来增加kafka主题分区计数？
-
我们的生产环境中出现了随机的和： 我们偶尔会在我的生产者日志中得到这个异常： 主题：XXXXXX：5608 ms的过期记录自批量创建加上逗留时间以来已经过去。 此类错误消息中的毫秒数不断变化。有时是5秒，有时是13秒！ 我们很少能得到： 集群由3个经纪人和3个动物园管理员组成。生产者服务器和Kafka集群在同一个网络中。 我在打同步电话。有一个web服务，多个用户请求调用它来发送数据。Kafka
-
我用Flink来读写来自不同Kafka主题的数据。具体来说，我使用的是FlinkKafkaConsumer和FlinkkafKapProducer。 我想知道是否有可能根据我程序中的逻辑或记录本身的内容，将我正在阅读和写作的Kafka主题更改为“即时”。 例如，如果读取带有新字段的记录，我希望创建一个新主题，并开始将带有该字段的记录转移到新主题。 谢谢。