常用命令

##连接ZK

./zkCli.sh -timeout 5000 -server 127.0.0.1:2181

##quit 退出

./zkServer.sh start | stop | status | help | restart

#kafka 配置详解 https://www.cnblogs.com/alan319/p/8651434.html

#Send

./kafka-console-producer.sh --broker-list 172.16.35.30:9091 --topic crosstrade

#消费消息

./kafka-console-consumer.sh --bootstrap-server xxx.xx.xx.xx:9091 --topic crosstrade --from-beginning

##topic 详细信息

./kafka-topics.sh --zookeeper 192.168.xx.xx:2181 --describe --topic springCloudBus

#topic 列表

./kafka-topics.sh --zookeeper 127.0.0.1:2181 --list

#创建topic

./kafka-topics.sh --create --zookeeper 127.0.0.1:2181 --replication-factor 1 --partitions 2 --topic searchxx

##为topic增加分区

./kafka-topics.sh --zookeeper 192.168.xx.xx:2181 --alter --partitions 2 --topic springcloudbus

#查看server节点信息

./kafka-topics.sh --describe --zookeeper 127.0.0.1:2181 --topic search

#查看分组 OK

./kafka-consumer-groups.sh --zookeeper 127.0.0.1:2181 --list

sh /data/kafka_2.11-0.10.1.1/bin/kafka-consumer-groups.sh --new-consumer --bootstrap-server 172.16.35.30:9091 --list

#参考分组消费情况 OK

sh /data/kafka_2.11-0.10.1.1/bin/kafka-consumer-groups.sh --group cic_groupXXXX --describe --zookeeper 127.0.0.1:2181

TOPIC  topic名字

PARTITION  分区id

CURRENT-OFFSET 当前已消费的条数

LOG-END-OFFSET 总条数

LAG 未消费的条数

CONSUMER-ID 消费id

HOST 主机ip

CLIENT-ID 客户端id

#查看分组明细

sh /data/kafka_2.11-0.10.1.1/bin/kafka-consumer-groups.sh --group cic_groupXXXX --describe --bootstrap-server 172.16.35.30:9091

#启动

bin/kafka-server-start.sh ../config/server-1.properties &

bin/kafka-server-start.sh -daemon config/server-1.properties

"-daemon" 参数代表以守护进程的方式启动kafka server。