MAC OS系统下kafka的安装

By prince No comments

安装zookeeper:

brew install kafka

程序安装目录(安装过程将依赖安装 zookeeper):

/usr/local/Cellar/zookeeper
/usr/local/Cellar/kafka

默认配置文件地址:

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

主要配置:

broker.id=0
num.network.threads=3
num.io.threads=8
socket.receive.buffer.bytes=102400
socket.request.max.bytes=104857600
log.dirs=/usr/local/var/lib/kafka-logs
num.partitions=1
num.recovery.threads.per.data.dir=1
offsets.topic.replication.factor=1
transaction.state.log.replication.factor=1
transaction.state.log.min.isr=1
log.retention.hours=168
log.segment.bytes=1073741824
log.retention.check.interval.ms=300000
zookeeper.connect=localhost:2181
zookeeper.connection.timeout.ms=6000
group.initial.rebalance.delay.ms=0

通过brew services插件启动:

brew services start zookeeper
brew services start kafka

或者直接启动:

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

创建topic:

kafka-topics --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test

查看创建的topic:

kafka-topics --list --zookeeper localhost:2181

发送一些消息:

kafka-console-producer --broker-list localhost:9092 --topic test

消费消息:

kafka-console-consumer --bootstrap-server localhost:9092 --topic test --from-beginning

关闭:

brew services stop kafka

或者这样关闭:

kafka-server-stop

发表评论

 

此站点使用Akismet来减少垃圾评论。了解我们如何处理您的评论数据