黑猴子的家：xkafka-consume.sh

#!/bin/bash
kafka_home=/opt/module/kafka-3.2.1
# 低版本
#${kafka_home}/bin/kafka-console-consumer.sh --zookeeper hadoop102:2181,hadoop103:2181,hadoop104:2181 --topic $1
# 高版本
#${kafka_home}/bin/kafka-console-consumer.sh --bootstrap-server hadoop102:9092,hadoop103:9092,hadoop104:9092 --topic $1
# 从头开始消费
#${kafka_home}/bin/kafka-console-consumer.sh --bootstrap-server hadoop102:9092,hadoop103:9092,hadoop104:9092 --from-beginning --topic $1

case $1 in
    start)
        ${kafka_home}/bin/kafka-console-consumer.sh --bootstrap-server hadoop102:9092,hadoop103:9092,hadoop104:9092 --from-beginning --topic $2
    ;;
    stop)
        ${kafka_home}/bin/kafka-console-consumer.sh --bootstrap-server hadoop102:9092,hadoop103:9092,hadoop104:9092 --topic $2
    ;;
    *)
        echo "你启动的姿势不对"
        echo "  start  从头开始消费，包含历史数据"
        echo "  stop   从当前时刻开始消费"
    ;;
esac