KafKa 安装及简单操作
安装 kafka
安装 java 11，为了方便选择 yum 安装
sudo yum -y install java-11-openjdk*下载 Kafka ，在官网选择下载时请选择二进制下载
wget http://apache.cs.utah.edu/kafka/2.3.0/kafka_2.11-2.3.0.tgz解压 Kafka
tar -zxvf kafka_2.11-2.3.0.tgz重命名解压文件
mv kafka_2.11-2.3.0 kafka进入解压文件
cd kafka运行 kafka
(1) 启动 Zookeeper
- linux:
bin/zookeeper-server-start.sh -daemon config/zookeeper.properties- windows:
zkServer(2) 启动kafka
- linux:
bin/kafka-server-start.sh config/server.properties- windows:
.\bin\windows\kafka-server-start.bat .\config\server.properties操作 kafka：
查看topic list
- linux:
bin/kafka-topics.sh --list --bootstrap-server localhost:9092- windows:
.\bin\windows\kafka-topics.bat --list --zookeeper localhost:2181创建topic
- linux:
bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test- windows:
.\bin\windows\kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test创建生产者
- linux:
bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test- windows:
.\bin\windows\kafka-console-producer.bat --broker-list localhost:9092 --topic test创建消费者
- linux:
bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning- windows:
.\bin\windows\kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic test --from-beginning