bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test
Error while executing topic command replication factor: 1 larger than available
brokers: 0
kafka.admin.AdminOperationException: replication factor: 1 larger than available
brokers: 0
at kafka.admin.AdminUtils$.assignReplicasToBrokers(AdminUtils.scala:70)
at kafka.admin.AdminUtils$.createTopic(AdminUtils.scala:171)
at kafka.admin.TopicCommand$.createTopic(TopicCommand.scala:93)
at kafka.admin.TopicCommand$.main(TopicCommand.scala:55)
at kafka.admin.TopicCommand.main(TopicCommand.scala)
[2015-10-13 14:25:38,607] INFO Processed session termination for sessionid: 0x15
06056566d0004 (org.apache.zookeeper.server.PrepRequestProcessor)
[2015-10-13 14:25:38,608] INFO Closed socket connection for client /127.0.0.1:33
391 which had sessionid 0x1506056566d0004 (org.apache.zookeeper.server.NIOServer
Cnxn)
服务器似乎未启动,请检查日志中的问题
压井工艺
sudo fuser -k 2181/tcp
运行zookeeper
bin/zookeeper-server-start.sh config/zookeeper.properties
bin/kafka-server-start.sh config/server.properties '
使用命令时: /usr/local/kafka/bin/kafka-topics.sh--创建--zookeeper localhost:2181--复制-因子1--分区1--主题测试 提前道谢。
我从Apache Kakfa开始,用Java开发一个简单的生产者、消费者应用程序。我正在使用kafka客户端,并在Mac上运行它。 我创建了一个名为“replicated\u topic\u partitioned”的主题,其中包含3个分区,复制因子为3。 我在2181港启动了动物园管理员。我在端口9092、9093和9094上分别启动了三个id为1、2和3的代理。 下面是descripe命令的输
本文向大家介绍解释术语“主题复制因子”。相关面试题,主要包含被问及解释术语“主题复制因子”。时的应答技巧和注意事项,需要的朋友参考一下 答:在设计Kafka系统时,考虑主题复制是非常重要的。
我正在学习使用Kafka在科特林的SpringKafka。我知道,当一个新主题发布时,如果不存在,它就会被创建。所以,当我向从Spring创建的新/旧主题发送一个值时,默认分区是0,但我想在另一个分区上写一条消息,比如分区1。 当我创建/写一个主题时,它是有效的: 但是,当我使用以下选项选择分区和密钥时: 我得到了以下错误: 我试着把钥匙换成,但也没用。显然,当我从Spring客户端创建一个主题时
在多次尝试并更改bat文件后,我终于成功地在Windows 7中运行了Kafka和Zookeeper。这是一台运行Java 7的32位计算机。但不幸的是,我无法创建主题。我尝试在这里使用教程:http://janschulte.wordpress.com/2013/10/13/apache-kafka-0-8-on-windows/ 我执行了命令: C:\Cambria\kafka_2.8.0-0