kafka 使用

安装

brew install kafka

使用

./zookeeper-server-start  /usr/local/etc/kafka/zookeeper.properties

/usr/local/Cellar/kafka/0.11.0.1/bin/kafka-server-start /usr/local/etc/kafka/server.properties

/usr/local/Cellar/kafka/0.11.0.1/bin/kafka-topics --create --topic test1  --replication-factor 1 --partitions 4 --zookeeper localhost:2181

这里创建了一个test消息队列，副本为1（小于等于集群数量），分区为4。

/usr/local/Cellar/kafka/0.11.0.1/bin/kafka-topics --list --zookeeper localhost:2181

/usr/local/Cellar/kafka/0.11.0.1/bin/kafka-topics --describe --topic test1 --zookeeper localhost:2181

/usr/local/Cellar/kafka/0.11.0.1/bin/kafka-console-producer --broker-list localhost:9092 --topic test1

/usr/local/Cellar/kafka/0.11.0.1/bin/kafka-console-consumer  --zookeeper localhost:2181  --topic test1 --from-beginning