zookeeper - 旧版Kafka的参数

bootstrap.server - 新版Kafka的参数

Kafka 命令行操作

Kafka的Topic增删改查都用下面这个

1
kafka-topics.sh

1)查看当前服务器中的所有 topic

--list

1
kafka-topics.sh --bootstrap-server:9092 --list

2)创建topic

--create

1
kafka-topics.sh --bootstrap master:9092 --create --replication-factor 3 --partitions 1 --topic first

选项说明:

  • –topic 定义topic名
  • –replication-factor 定义副本数
  • –partitions 定义分区数

3)删除topic

--delete

1
kafka-topics.sh --bootstrap master:9092 --delete --topic first