kafka 环境搭建
安装
下载kafka
1
| curl -L -O https://mirrors.cnnic.cn/apache/kafka/2.0.0/kafka_2.12-2.0.0.tgz
|
解压
1
| tar -xvf kafka_2.12-2.0.0.tgz -C /usr/local/kafka
|
配置zookeeper
zookeeper安装
配置zookeeper
1
| vi config/server.properties
|
找到zookeeper.connect,并将值修改为zookeeper的地址,如
1
| zookeeper.connect=localhost:2181
|
启动kafka
1
| /usr/local/kafka/bin/kafka-server-start.sh /usr/local/kafka/config/server.properties
|
查看kafka是否启动
1
| netstat -tunlp|egrep "(2181|9092)"
|
单机测试
启动两个xshell客户端分别作为生产者和消费者
- 生产者测试
1
2
| ./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
1
| ./kafka-topics.sh --list --zookeeper localhost:2181
|