亚洲激情专区-91九色丨porny丨老师-久久久久久久女国产乱让韩-国产精品午夜小视频观看

溫馨提示×

怎么使用kafka命令查看topic消費情況

小億
1602
2024-01-25 00:22:17
欄目: 編程語言

要使用Kafka命令查看topic的消費情況,可以使用以下命令:

  1. 查看消費者組信息:
kafka-consumer-groups.sh --bootstrap-server <kafka服務器地址> --group <消費者組名稱> --describe

這將顯示給定消費者組的消費者的詳細信息,包括當前消費的topic、消費的偏移量等。

  1. 查看特定topic的消費者偏移量:
kafka-run-class.sh kafka.tools.GetOffsetShell --broker-list <kafka服務器地址> --topic <topic名稱> --time -1

這將顯示給定topic的每個分區的消費者偏移量。

  1. 查看特定topic的消費者組消費情況:
kafka-consumer-groups.sh --bootstrap-server <kafka服務器地址> --group <消費者組名稱> --topic <topic名稱> --describe

這將顯示給定消費者組在特定topic上的消費情況,包括每個消費者的偏移量和lag(與最新消息的偏移量之差)。

請確保將<kafka服務器地址><消費者組名稱><topic名稱>替換為實際的值。

0
积石山| 安平县| 咸丰县| 龙陵县| 上栗县| 荥经县| 伽师县| 永春县| 仙居县| 商都县| 西乌珠穆沁旗| 萝北县| 漳州市| 平定县| 治多县| 乐至县| 兰考县| 和林格尔县| 太谷县| 天气| 洪雅县| 孟津县| 隆子县| 建始县| 通海县| 榆树市| 祁阳县| 敦煌市| 稷山县| 芜湖县| 广德县| 兴文县| 沾益县| 临澧县| 禄丰县| 晋宁县| 富民县| 南江县| 桐乡市| 长汀县| 永泰县|