当前位置: 首页 > 网络应用技术

日志末端出现:当前最高水位偏移量,这是消息的最新偏移,最近的偏移量提交给群集

时间:2023-03-06 16:14:19 网络应用技术

  在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