首页 › pyspark › 正文

如何获取创建过的kafka topic group id

发布时间:2018-09-12T15:14:20:手机请访问

kafka python kafka

0

首先进入 kafka的安装目录

如何获取创建过的kafka topic group id-新乡seo|网站优化,网站建设_微信公众号:zeropython—昊天博客

运行下面的命令

./zookeeper-shell.sh localhost:2181

1 2	./zookeeper-shell.sh localhost:2181

[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]

喜欢 (0)

SparkStreaming下Python报net.jpountz.lz4.LZ4BlockInputStream的解决

Python Spark 链接 MongoDB

发表评论点击这里取消回复。