Kafka运维备忘

# 登录测试
kafkacat -b 172.16.0.189:9092 \
  -X security.protocol=SASL_PLAINTEXT \
  -X sasl.mechanisms=PLAIN \
  -X sasl.username=testUser \
  -X sasl.password=changeme \
  -L


# 按前缀修改数据保留时间
./kafka-topics.sh --list | grep '^PREFIX_' | while read topic; do
    ./kafka-configs.sh --bootstrap-server 172.16.0.189:9092 --entity-type topics --entity-name "$topic" --alter --add-config retention.ms=259200000 --command-config /opt/kafka/config/kraft/sasl.properties
    echo "$topic config done"
done

本文标题：Kafka运维备忘
本文连接：https://blog.dextercai.com/archives/247.html
除另行说明，本站文字内容采用创作共用版权 CC-BY-NC-ND 4.0 许可协议，版权归本人所有。
除另行说明，本站图片内容版权归本人所有，未经许可前，严禁以任何形式的使用。

---

即日起视情况关闭全站评论区，您可以通过关于页面的电邮地址和我取得联系，谢谢