Mars
0%

Kafka-Record

发表于 更新于

Kafka的命令一段时间不用总会有点遗忘，这边会记录我对Kafka的一些理解，今后会做一些Kafka源码方面的工作(但愿如此，也会在此延伸记录 ~

undefined

Kafka命令

Mac Brew安装的Kafka

位置：/usr/local/Cellar/kafka

查看所有Topic

1
kafka-topics --list --zookeeper localhost:2181
1
kafka-topics --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic topicname

Tips

如果想要这台电脑的Kafka能被别的电脑访问，那么有个问题是必须要注意的，那就是要自己修改server.properties里面的listeners=PLAINTEXT://192.168.31.130:9092的ip为绑定的ip，不能是localhost或者127.0.0.1，我记得之前zpl里面也是这样的，如果绑定的ip地址不正确，那么就会出现连接不上的问题。

命令行查看__consumer_offsets下保存的Offset

1
kafka-consumer-offset-checker --zookeeper localhost :2181/kafka --group test-consumer-group  --topic stable-test

结果：

1
2
3
4
5
[2017-08-22 19:24:24,222] WARN WARNING: ConsumerOffsetChecker is deprecated and will be dropped in releases following 0.9.0. Use ConsumerGroupCommand instead. (kafka.tools.ConsumerOffsetChecker$)
Group           Topic                          Pid Offset          logSize         Lag             Owner
test-consumer-group stable-test                    0   601808          601808          0               none
test-consumer-group stable-test                    1   602826          602828          2               none
test-consumer-group stable-test                    2   602136          602136          0               none

结果说明：

Group : 消费者组

Topic : topic的名字

Pid : partition的ID

Offset : kafka消费者在对应分区上已经消费的消息数【位置】

logSize : 已经写到该分区的消息数【位置】

Lag : 还有多少消息未读取（Lag = logSize - Offset）

Owner : 分区创建在哪个broker