我已经安装了kafka-0.8.2.2使用自制,如下面的链接所述https://dtflaneur.wordpress.com/2015/10/05/installing-kafka-on-mac-osx/
我只配置了一个代理。。
能够运行zookeeper,Kafka,消费者,生产者和发布消息使用生产者控制台,并看到消费者控制台中的消息。。。
但当我试图运行下面的脚本我看到这个脚本是失踪。。
kafka-consumer-groups.sh网站
基本上我想看看
消费群体列表
可用分区数(想知道代理中存在的分区数)
当我运行echo$kafka\u回家的时候,它是空的,我的意思是没有价值。。。
但是当我运行brew安装kafka时,警告:kafka-0.8.2.2已经安装
我很担心Kafka是否安装正确,请建议
在usr/local/bin下可以看到下面的脚本/
kafka-console-consumer.sh
kafka-console-producer.sh
kafka-consumer-offset-checker.sh
kafka-consumer-perf-test.sh
kafka-mirror-maker.sh
kafka-preferred-replica-election.sh
kafka-producer-perf-test.sh
kafka-reassign-partitions.sh
kafka-replay-log-producer.sh
kafka-replica-verification.sh
kafka-run-class.sh
kafka-server-start.sh
kafka-server-stop.sh
kafka-simple-consumer-shell.sh
kafka-topics.sh
不知道还有没有其他剧本不是我说的。。。
1条答案
按热度按时间vkc1a9a21#
kafka-consumer-groups.sh
仅适用于0.9
.每个主题(不是代理)都由分区组成,因此要 checkout 主题的分区,可以使用:
/bin/kafka-topics.sh --zookeeper localhost:2181 --describe --topic your_topic_name
我不知道如何安装kafka的brew,因为我使用的是docker,在docker中,您只需安装一个命令,就不会弄乱本地文件系统。我衷心建议你试试(如果你选择 Docker 的方式,我可以提供更多的细节)。