时间:2017年10月
关键字:kafka、维护、常用、命令

显示topic列表

> bin/kafka-topics.sh --zookeeper 172.16.132.176:2181/kafka --list

创建topic

> bin/kafka-topics.sh --zookeeper 172.16.132.176:2181/kafka --create --replication-factor 3 --partitions 8 --topic topic001

删除topic

> bin/kafka-topics.sh --zookeeper 172.16.132.176:2181/kafka --delete --topic topic001

查看topic描述

> bin/kafka-topics.sh --zookeeper 172.16.132.176:2181/kafka --describe --topic topic001

显示group列表,java创建的group需要在zookeeper中查看

> bin/kafka-consumer-groups.sh --bootstrap-server 172.16.132.197:9092 --list

显示group描述

> bin/kafka-consumer-groups.sh --bootstrap-server 172.16.132.197:9092 --group group001 --describe

显示偏移情况

> bin/kafka-consumer-offset-checker.sh --zookeeper 172.16.132.176:2181/kafka --topic topic001 --group group001

控制台生产消息

> bin/kafka-console-producer.sh --broker-list 172.16.132.197:9092 --topic topic001

控制台消费消息

> bin/kafka-console-consumer.sh --bootstrap-server 172.16.132.197:9092 --topic topic001 --from-beginning

关键字:kafka、exception、kafka.network.Processor
时间:2017年8月

错误信息

Processor got uncaught exception: kafka.network.Processor
...

原因分析

仔细查看错误日志发现有host相关字样,才回想起,这台主机修改了/etc/hostname,并且已经重启。但新的hostname在/etc/hosts里面并没有,如下:

#/etc/hostname
kafka
#/etc/hosts
127.0.0.1    localhost
127.0.1.1    debian
...

修改debian为kafka,启动kafka-server-start.sh,一切正常。