kafka"/>
安装kafka
参考官网教程:
1. 从官网上获取下载地址并下载
wget .1.0/kafka_2.11-1.1.0.tgz
2. 解压即安装
tar -xvf kafka_2.11-1.1.0.tgz
3. 启动zookeeper
kafka使用zookeeper管理集群,可以使用kafka中自带的zookeeper
./bin/zookeeper-server-start.sh ./config/zookeeper.properties
使用默认的配置文件启动zookeeper,此时zookeeper以单机模式运行,使用端口2181接收来自Client的请求。
4. 配置kafka
启动kafka之前先配置kafka
vim config/server.properties
增加以下两个配置
host.name=0.0.0.0
advertised.host.name=192.168.204.128
- host.name表示kafka绑定到的ip上,此处设置为0.0.0.0,保证非本机的请求也能被接受
- advertised.host.name表示kafka注册到zookeeper时,将告诉zookeeper自己的地址为192.168.204.128,当消费者向zookeeper询问kafka的地址时,将会返回192.168.204.128,消费者会直接连向192.168.204.128拉取数据。
- 端口号不作修改,默认都为9092
- zk的连接也不作修改,默认为localhost:2181
如果要修改,可以自行配置
port=9092
advertised.port=9092
zookeeper.connect=localhost:2181
20180604更新:参数host.name/port/advertised.host.name/advertised.port在最新的官方文档标注为deprecated,应该为以下配置
listeners=PLAINTEXT://0.0.0.0:9092
advertised.listeners=PLAINTEXT://192.168.204.128:9092
5. 启动kafka
./bin/kafka-server-start.sh ./config/server.properties
6. 创建topic
./bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic mykafka
此处不创建也可以,kafka默认是自动创建topic,当你尝试发送到topic或订阅topic时,会自动创建topic
7. 发送消息
./bin/kafka-console-producer.sh --broker-list localhost:9092 --topic mykafka
8. 接收消息
./bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic mykafka --from-beginning
更多推荐
安装kafka
发布评论