CentOS 7下安装Kafka单机版

详细安装步骤

1. 下载kafka_2.10-0.10.0.0.tgz到/data/soft目录

2. 进入解压目录(在此为/data/app/Kafka/kafka_2.10-0.10.0.0/bin)，启动zookeeper服务。能够在命令的结尾加个&符号，这样服务就能够在后台运行

3. 启动kafka服务

kafka-server-start.sh ../config/server.properties &

ps -ef | grep kafka查看，观察到zookeeper和kafka服务已启动

验证

1. 建立一个叫"test1234"的topic，它只有一个分区，一个副本：

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

能够用list查看建立的topic

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

2. 发送消息。运行producer并在控制台中输一些消息，这些消息将被发送到服务端

kafka-console-producer.sh --broker-list localhost:9092 --topic test1234

3. 在另外一个终端开启consumer，能够读取到刚才发出的消息并输出。

kafka-console-consumer.sh --zookeeper localhost:2181 --topic test1234 --from-beginning