文章目录
- 命令1
- 命令2
- 命令3
- 命令4
- 命令5
- 命令6
- 命令7
- 命令8
- 命令9 其他说明
提示:以下是本篇文章正文内容,Kafka 0.9.x 及更高版本中使用
在使用 Kafka 命令行工具时,–zookeeper 和 --bootstrap-server 参数用于指定不同的连接信息,具体取决于你使用的命令以及 Kafka 版本。
--zookeeper
–zookeeper 参数主要用于较早版本的 Kafka 命令,特别是 Kafka 0.8.x 及之前版本。这个参数用来指定 ZooKeeper 的连接字符串,因为早期的 Kafka 使用 ZooKeeper 来管理集群元数据。
举例:
kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test-topic
--bootstrap-server
–bootstrap-server 参数则是在 Kafka 0.9.x 及更高版本中引入的。它用于指定一个或多个 Kafka broker 的地址,通常用于启动消费者、生产者以及其他不需要直接与 ZooKeeper 交互的命令。
举例:
kafka-topics.sh --create --bootstrap-server localhost:9092 --replication-factor 1 --partitions 1 --topic test-topic
命令1
- 创建topic
说明:
--partitions 3
指创建3个分区。
--replication-factor 1
这意味着每个分区只有一个副本,即没有冗余副本。在这种情况下,如果存储该分区的 broker 发生故障,那么该分区的数据将不可用,直到 broker 恢复。这通常用于测试环境或资源有限的情况。如果不带replication-factor参数,默认值为1
kafka-topics.sh --create --bootstrap-server localhost:9092 --replication-factor 1 --partitions 3 --topic test-topic或这样写也可以
kafka