基于kafka_2.11-0.10.0.1版本:
查看kafka的安装目录
find / -name kafka* -type d查看redis安装目录:
ps -ef|grep redis查询所有group信息:
./bin/kafka-topics.sh --list --zookeeper localhost:2181查询指定topic的详细信息:
./bin/kafka-topics.sh --describe --zookeeper localhost:2181 --topic paymentmgt_download_asyn_deal示例结果:
Topic:paymentmgt_download_asyn_deal PartitionCount:3 ReplicationFactor:1 Configs: Topic: paymentmgt_download_asyn_deal Partition: 0 Leader: 0 Replicas: 0 Isr: 0 Topic: paymentmgt_download_asyn_deal Partition: 1 Leader: 0 Replicas: 0 Isr: 0 Topic: paymentmgt_download_asyn_deal Partition: 2 Leader: 0 Replicas: 0 Isr: 0
创建topic:paymentmgt_download_asyn_deal
./bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 3 --topic paymentmgt_download_asyn_dealtopic的名称必须由大小写字母、数字、“.”、“-”、“_”组成，不能为空、不能为“.”、不能为“…”，且长度不能超过249。
topic的命名同样不推荐（虽然可以这样做）使用双下划线“__”开头，因为以双下划线开头的topic一般看作是kafka的内部topic，比如__consumer_offsets和__transaction_state。
查询指定group的topic信息:
./bin/kafka-consumer-groups.sh --zookeeper localhost:2181 --describe --group paymentmgt查询指定topic的消息内容:
./kafka-console-consumer.sh --zookeeper localhost:2181 --topic paymentmgt_download_asyn_deal --from-beginning查询匹配指定内容的消息内容:
./bin/kafka-console-consumer.sh --zookeeper 127.0.0.1:2181,127.0.0.1:2182 --topic paymentmgt_download_asyn_deal --from-beginning | grep ""消息发送:
./bin/kafka-console-producer.sh --broker-list 192.168.1.94:9092 --topic paymentmgt_download_asyn_deal 消息消费:
./bin/kafka-console-consumer.sh --zookeeper localhost:2181 --topic paymentmgt_download_asyn_deal通过查看消费者组信息如下: CURRENT-OFFSET是指当前偏移量, LOG-END-OFFSET是指结束的偏移量， LAG是指落后的偏移量.
GROUP TOPIC PARTITION CURRENT-OFFSET LOG-END-OFFSET LAG OWNER
版权声明：本文内容由互联网用户自发贡献，该文观点仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请联系我们举报，一经查实，本站将立刻删除。
发布者：全栈程序员-站长，转载请注明出处：https://javaforall.net/229495.html原文链接：https://javaforall.net
