Kafka 环境变量配置

export KAFKA_HOME=/opt/cloudera/parcels/CDH-6.3.2-1.cdh6.3.2.p0.1605554/lib/kafka
export PATH=$PATH:$KAFKA_HOME/bin

查看主题

./kafka-topics.sh --list --zookeeper localhost:2181

创建主题

./kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic topic_name

删除主题

./kafka-topics.sh --zookeeper localhost:2181 --delete --topic topic_name

清空消息

./kafka-topics.sh --zookeeper localhost:2181 --alter --topic topic_name --config retention.ms=1000

查看消息

./kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic topic_name --from-beginning

写入消息

echo ‘test_message’ | kafka-console-producer --broker-list localhost:9092 --topic topic_name