黑猴子的家：consume.sh
2021-08-23 本文已影响0人
黑猴子的家
#!/bin/bash
kafka_home=/opt/module/kafka
# 低版本
$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
