首先进入 kafka的安装目录

运行下面的命令

Python
./zookeeper-shell.sh localhost:2181
1
2
. / zookeeper - shell . sh localhost : 2181
 
Python
[root@localhost bin]# ./zookeeper-shell.sh localhost:2181 Connecting to localhost:2181 Welcome to ZooKeeper! JLine support is disabled WATCHER:: WatchedEvent state:SyncConnected type:None path:null # 然后输入 ls /consumers # 返回的就是 group id [console-consumer-50232, spark-streaming-consumer]
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
[ root @ localhost bin ] # ./zookeeper-shell.sh localhost:2181
 
Connecting to localhost : 2181
 
Welcome to ZooKeeper !
 
JLine support is disabled
 
WATCHER ::
WatchedEvent state : SyncConnected type : None path : null
 
# 然后输入
 
ls / consumers
# 返回的就是 group id
[ console - consumer - 50232 , spark - streaming - consumer ]
 



  • zeropython 微信公众号 5868037 QQ号 5868037@qq.com QQ邮箱
Logo
Kafka开源项目指南

Kafka开源项目指南提供详尽教程，助开发者掌握其架构、配置和使用，实现高效数据流管理和实时处理。它高性能、可扩展，适合日志收集和实时数据处理，通过持久化保障数据安全，是企业大数据生态系统的核心。

更多推荐

cover

zookeeper+kafka群集

avatar Kafka开源项目指南

KubeSphere 部署 Kafka 集群实战指南

本文档将详细阐述如何利用 Helm 这一强大的工具，快速而高效地在 K8s 集群上安装并配置一个 Kafka 集群。

avatar Kafka开源项目指南
cover

zookeeper+kafka+ELK+filebeat集群

avatar Kafka开源项目指南