在Kafka 0.9.0.0之后,出现了一些新的更改。一种是将组协调器的角色添加到服务器端。另一个是将主题办公室的信息从先前存储的Zookeeper更改为特殊。
后台居民方法,带来参数-daemon,例如:
指定JMX端口的开始,并指定JMX,可以轻松监视KAFKA群集
[使用ZK] - Zookeeper localhost:2181
[内置] -buotstrap-server localhost:9092
1.创建主题2.列出所有主题
3.查看指定的主题
4.增加主题分区的数量
5.查看主题指定分区的最大值或最小值偏移,以指示-1时的最大值,最小值为-2:
6.删除主题1.从开始到开始2.从尾巴开始,您必须指定分区:
3.指定分区4.采用指定的编号1.指定组2.消费者组列表3.查看组详细信息[用于确定是否存在延迟数据]输出]输出
主题分区当前扣入记录销售滞后消费者ID主机客户ID测试0 5 5 0--
kafka-consumer-founds.sh-buotstrap-server localhost:9092组test_group-deletee
分区:指定领导者的分区编号
kafka-producucucer-perf-tesh-Tesh-Test test-test-num records 100 record-size 1-Thoughput 100-Producer-pootservers = localhost:90922:90922:90922:90922:90922:90922:90922:909222:909222
原始:https://juejin.cn/post/7097165751890477087