首先进入 kafka的安装目录

运行下面的命令
1 2 |
./zookeeper-shell.sh localhost:2181 |
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] |

