# KAFKA操作記錄

##

export BASE_DIR='/home/dba/kafka'

export SERVERS='1.1.1.1:9092'

cd ${BASE_DIR}/bin

# 刪除殘留的消費者

./kafka-consumer-groups.sh --bootstrap-server $SERVERS --group DBAAlertSplash --delete --command-config ${BASE_DIR}/config/client.properties

# 這個在服務啟動時使用? export KAFKA_OPTS="-Djava.security.auth.login.config=/home/dba/kafka/config/kafka_client_plain_jaas.conf"

# 列出

./kafka-consumer-groups.sh --bootstrap-server ${SERVERS} --group DBAAlertSplash --describe --command-config ${BASE_DIR}/config/client.properties

# 預執行

./kafka-consumer-groups.sh --bootstrap-server ${SERVERS} --group DBAAlertSplash --topic db_alert --reset-offsets --to-earliest --command-config ${BASE_DIR}/config/client.properties --dry-run

# 執行

./kafka-consumer-groups.sh --bootstrap-server ${SERVERS} --group DBAAlertSplash --topic db_alert --reset-offsets --to-earliest --command-config ${BASE_DIR}/config/client.properties --execute

./kafka-consumer-groups.sh --bootstrap-server ${SERVERS} --group DBAAlertSplash --topic db_alert --reset-offsets --to-offset 200816 --command-config ${BASE_DIR}/config/client.properties --execute

參考文章：

總結

以上是生活随笔為你收集整理的kafka偏移量保存到mysql里_【队列】调试应用时进行的kafka偏移量调整的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。