【隊列】調試應用時進行的kafka偏移量調整

# 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

參考文章：

• how_to_reset_kafka_consumer_group_offset.md
• Kafka安全認證SASL下附帶工具的配置使用
• Kafka經常使用命令(帶SASL權限版)
• kafka 0.11 reset offset for consumer group by --to-datetime