赞
踩
两种方式一种免安装版,一种安装版 免安装版已经吧命令默认加入全局命令,无需指定启动脚本。
两种方式都需要zookeeper,因为kafka依赖使用zookeeper具体就不再这里赘述。
brew install zookeeper
zookeeper安装目录:/usr/local/Cellar/zookeeper/
zookeeper的配置文件位置:/usr/local/etc/zookeeper/zookeeper.properties
brew install kafka
kafka安装路径:/usr/local/Cellar/kafka/
kafka的配置文件位置:/usr/local/etc/kafka/server.properties
文件位置 /usr/local/etc/kafka/server.properties
listeners=PLAINTEXT://:9092修改为listeners=PLAINTEXT://localhost:9092
需要先启动zookeeper,之后启动kafka
1.3.1 启动zookeeper
后台启动运行
nohup zookeeper-server-start /usr/local/etc/kafka/zookeeper.properties &
后台启动运行
nohup kafka-server-start /usr/local/etc/kafka/server.properties &
kafka-topics --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test
kafka-topics --list --zookeeper localhost:2181
kafka-console-producer -topic test --broker-list localhost:9092
需要新建一个终端窗口
kafka-console-consumer --bootstrap-server localhost:9092 -topic test
发送消息
接收消息
地址:https://www.apache.org/dyn/closer.cgi?path=/kafka/0.8.1.1/kafka_2.9.2-0.8.1.1.tgz
tar -xzf kafka_2.9.2-0.8.1.1.tgz
cd kafka_2.9.2-0.8.1.1
可以把压缩文件复制到任意地方,然后进入根目录
复制到software目录下 没有的话自己创建或者自己选择合适的目录
cp ~/Downloads/kafka_2.9.2-0.8.1.1 /Users/software/kafka_2.9.2-0.8.1.1
进入根目录
cd /Users/software/kafka_2.9.2-0.8.1.1
启动zookeeper
./bin/zookeeper-server-start.sh config/zookeeper.properties
./bin/kafka-server-start.sh config/server.properties
./bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test
./bin/kafka-topics.sh --list --zookeeper localhost:2181
./bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test
./bin/kafka-console-consumer.sh --zookeeper localhost:2181 --topic test --from-beginning
免安装版使用方式和安装版使用方式一样我就不上图了。
Copyright © 2003-2013 www.wpsshop.cn 版权所有,并保留所有权利。