编程开源技术交流,分享技术与知识

网站首页 > 开源技术 正文

三分钟学会kafka常用命令(kafka常见命令)

wxchong 2024-10-19 15:49:31 开源技术 38 ℃ 0 评论

1.开启zookeeper集群 startzk.sh

2.开启kafka集群 start-kafka.sh

3.开启kafka可视化界面 kafka-manager : start-kafka-manager.sh

4.生产者操作:

kafka-console-producer.sh --broker-list node1:9092 --topic my-kafka-topic //topic name

5.消费者操作:

kafka-console-consumer.sh --bootstrap-server node1:9092 --topic my-kafka-topic

# 通过以上命令,可以看到消费者可以接收生产者发送的消息

# 如果需要从头开始接收数据,需要添加--from-beginning参数

kafka-console-consumer.sh --bootstrap-server node01:9092 --from-beginning --topic my-kafka-topic

6.topic 操作

a.创建topic

kafka-topics.sh --create --zookeeper node1:2181 --replication-factor 1 --partitions 1 --topic my-kafka-topic

b.查看topic列表

kafka-topics.sh --list --zookeeper node01:2181

c.如果需要查看topic的详细信息,需要使用describe命令

kafka-topics.sh --describe --zookeeper node1:2181 --topic test-topic

d.若不指定topic,则查看所有topic的信息

kafka-topics.sh --describe --zookeeper node1:2181

e.删除topic

kafka-topics.sh --delete --zookeeper node1:2181 --topic my-kafka-topic

Tags:

本文暂时没有评论,来添加一个吧(●'◡'●)

欢迎 发表评论:

最近发表
标签列表