Kafka的安装与配置

Mac中kafka2.1.0安装和测试

kafka的安装,在安装kafka会将其依赖的zookeeper下载

brew install kafka

进入到/usr/local/Cellar 路径之下会看见软件位置

/usr/local/Cellar/zookeeper

/usr/local/Cellar/kafka

其中的配置文件都在kafka路径之下的config 目录里面

/usr/local/Cellar/kafka/config

启动zookeeper

zookeeper-server-start /usr/local/Cellar/kafka/2.1.0/libexec/config/zookeeper.properties &

启动kafka服务

kafka-server-start /usr/local/Cellar/kafka/2.1.0/libexec/config/server.properties &

创建topic  zhang

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

查看创建的topic

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

生产者生产数据

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

消费者消费数据

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