kafka-04 kafka命令行操作

Kafka命令行操作

• 查看当前服务器中所有topic
  • 3.0使用--bootstrap-server

bin/kafka-topics.sh --list --zookeeper hadoop001:2181

• 创建topic
  • topic参数定义topic名
  • replication-factor参数定义副本数
    • 1个副本就是它自己
    • 副本数不能超高机器数
  • partitions参数定义分区数
    • 一个机器可能有多个分区

bin/kafka-topics.sh --create --topic first --partitions 1 --replication-factor 2 --zookeeper hadoop001:2181 

• 删除topic
  • 需要server.properties中设置delete.topic.enable=true 否则只是标记为删除

bin/kafka-topics.sh --delete --topic first --zookeeper hadoop001:2181

• 0 1 表示分区号
• 生产者
  • 连接broker-list kafka集群

bin/kafka-console-producer.sh --topic first --broker-list hadoop001:9092

• 消费者
  • 连接bootstrap-server kafka集群

bin/kafka-console-consumer.sh --topic first --bootstrap-server hadoop001:9092

重置kafka

• 删除data和logs目录
• 删除zk中路径
  • bin/zkCli.sh
  • ls /
• 也可
  • 停止zookeeper
  • 删除zkData下version文件夹