怪咖晨

kafka 环境搭建

。一笑奈何 kafkalinux

kafka 搭建

安装

下载kafka

curl -L -O https://mirrors.cnnic.cn/apache/kafka/2.0.0/kafka_2.12-2.0.0.tgz

解压

tar -xvf kafka_2.12-2.0.0.tgz -C /usr/local/kafka

配置zookeeper

zookeeper安装

配置zookeeper

vi config/server.properties

找到zookeeper.connect,并将值修改为zookeeper的地址,如

zookeeper.connect=localhost:2181

启动kafka

/usr/local/kafka/bin/kafka-server-start.sh /usr/local/kafka/config/server.properties

查看kafka是否启动

netstat -tunlp|egrep "(2181|9092)"

单机测试

启动两个xshell客户端分别作为生产者消费者

  1. 生产者测试
./kafka-console-producer.sh --broker-list localhost:9092 --topic test
> hello world!
  1. 消费者测试
./kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning

注意: 早期的kafka版本,消费者参数用的是–zookeeper,填写的值是zookeeper的地址,在我们今天教程中的版本参数应该是 –bootstrap-server,填写的是kafka的broker地址

查看topic

./kafka-topics.sh --list --zookeeper localhost:2181
。一笑奈何
高山仰止,景行行止。虽不能至,心向往之