【Kafka】常用操作

创建topic

• 创建一个名为hello的topic，只有一个副本，一个分区

cd /opt/kafka_2.13-2.5.0

sh bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic hello

查看topic

• 查看已经创建的 topic

cd /opt/kafka_2.13-2.5.0

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

简单测试

• 在一个新的远程窗口启动Producer

cd /opt/kafka_2.13-2.5.0

sh bin/kafka-console-producer.sh --broker-list 192.168.247.132:9092 --topic hello

• 在一个新的远程窗口启动Consumer

cd /opt/kafka_2.13-2.5.0

sh bin/kafka-console-consumer.sh --bootstrap-server 192.168.247.132:9092 --topic hello --from-beginning

• 在Producer窗口发送消息

• 查看Consumer窗口，接收到消息

Kafka的日志在logs文件夹里面

删除Kafka全部数据

1. 停止Kafka进程
2. 删除Kafka存储目录（server.properties文件log.dirs配置，默认为“/tmp/kafka-logs”）全部topic的数据目录
3. 删除Zookeeper上与Kafka相关的znode节点；除了/zookeeper
4. 重启Kafka