0


Kafka

1. 指令

1.1 修改配置文件

vi /data/software/kafka/config/server.properties

在这里插入图片描述
在这里插入图片描述

1.2 启动

先进入kafka安装目录 bin下

  • 先启动zookeeper
zookeeper-server-start.sh -daemon  /data/software/kafka/config/zookeeper.properties
  • 启动 kafka server
kafka-server-start.sh -daemon /data/software/kafka/config/server.properties
  • 创建主题 分区1 副本1
kafka-topics.sh --zookeeper IP:2181 --create --topic mytest --replication-factor 1  --partitions 1
  • 查看所有主题
kafka-topics.sh --list --bootstrap-server IP:9092
  • 开启生产者
kafka-console-producer.sh  --broker-list  IP:9092 --topic  主题
  • 开启消费者 一个主题的一个分区数据可以被不同的消费者组消费
kafka-console-consumer.sh --bootstrap-server  IP:9092 --topic 主题 --from-beginning
kafka-console-consumer.sh --bootstrap-server IP:9092 --topic 主题--consumer-property group.id=消费者组

1.3 操作

  • 查看主题详情
kafka-topics.sh --zookeeper IP:2181 --describe --topic mytest
  • 查看消费者组
kafka-consumer-groups.sh --bootstrap-server IP:9092 --list
  • 查看消费者组详情
kafka-consumer-groups.sh --bootstrap-server IP:9092 --group 组名 --describe
标签: kafka 分布式

本文转载自: https://blog.csdn.net/abcd741258358/article/details/131539271
版权归原作者 陳小新 所有, 如有侵权,请联系我们删除。

“Kafka”的评论:

还没有评论