连接远程kafka服务，排查问题

✅ 二、如何在本地（非 Kafka 服务器）执行？
你不需要运行 Kafka broker，只需 下载 Kafka 客户端工具：
步骤：
下载 Kafka（任意版本，与集群兼容即可）
bash

编辑

wget https://archive.apache.org/dist/kafka/3.6.0/kafka_2.13-3.6.0.tgz
tar -xzf kafka_2.13-3.6.0.tgz
cd kafka_2.13-3.6.0
配置网络可访问 Kafka 集群
确保你的机器能访问 Kafka 的 bootstrap-server 地址（如 kafka.prod.example.com:9092）；
如果有 SASL/SSL 认证，需额外配置 JAAS 或 SSL 参数。
执行命令
bash

编辑

bin/kafka-consumer-groups.sh \

查看kafka的消费组相关信息

bin/kafka-consumer-groups.sh \--bootstrap-server your-kafka-broker:9092 \--group slice-group \--describe

--bootstrap-server your-kafka-broker:9092 \
--group slice-group \
--describe

🔐 如果 Kafka 启用了安全认证（SASL_SSL），你需要创建一个 client.properties 文件：
properties

编辑

security.protocol=SASL_SSL
sasl.mechanism=PLAIN
sasl.jaas.config=org.apache.kafka.common.security.plain.PlainLoginModule required username="xxx" password="yyy";
ssl.truststore.location=/path/to/truststore.jks
然后加参数：--command-config client.properties
✅ 三、输出示例说明
bash

编辑

GROUP TOPIC PARTITION CURRENT-OFFSET LOG-END-OFFSET LAG
slice-group ai_to_dt_seg_extract 0 1005 1005 0
slice-group ai_to_dt_seg_extract 1 980 1000 20
LAG > 0：表示有消息未消费；
CURRENT-OFFSET 跳跃：比如从 1000 直接到 1002，说明 offset=1001 的消息可能被跳过（很可能就是你“丢失”的那条）。

修改kafka的topic的分区

bin/kafka-topics.sh --alter  --bootstrap-server 10.10x.1.xx:9092,10.10x.1.1xx:9092,10.xx6.1.xx:9092 --topic ai_to_dt_seg_extractxx  --partitions 3