# 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
参考文章：
原文：https://blog.51cto.com/l0vesql/2507579