Linux 安装 Kafka

1. 下载安装包

  官网下载地址:http://kafka.apache.org/downloads

  选择一个版本下载,然后解压安装包。

2. 基本使用

2.1 启动kafka 

  bin/zookeeper-server-start.sh -daemon config/zookeeper.properties
  bin/kafka-server-start.sh -daemon config/server.properties

  启动后查看进程状态:

  

  QuorumPeerMain:表示zookeeper进程;

  Kafka:表示kafka进程;

2.2 创建Topic

  bin/kafka-topics.sh --zookeeper localhost:2181  --partitions 1  --replication-factor 1 --create --topic ${topicName}

2.3 查看topic列表

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

2.4 查看某个Topic信息

  bin/kafka-topics.sh --zookeeper localhost:2181 --describe --topic ${topicName}

2.5 创建生产者

  bin/kafka-console-producer.sh   --broker-list localhost:9092   --topic ${topicName}

2.6 创建消费者

  bin/kafka-console-consumer.sh   --bootstrap-server  localhost:9092   --topic ${tpoicName}   --from-beginning

2.7 停止kafka

  bin/kafka-server-stop.sh

  bin/zookeeper-server-stop.sh

原文地址:https://www.cnblogs.com/virgosnail/p/10672768.html