启动Kafka和Zookeeper
现在的Kafka是内置Zookeeper的,只需在 kafka存放目录 下依次执行指令即可:
.\bin\windows\zookeeper-server-start.bat .\config\zookeeper.properties
.\bin\windows\kafka-server-start.bat .\config\server.properties
配置Kafka和Zookeeper的端口
配置Kafka端口
编辑 kafka存放目录/config/server.properties
添加或修改行:
listeners=PLAINTEXT://127.0.0.1:8102
其中 127.0.0.1 为监听地址,我们在编写生产/消费者程序时只能通过这个地址连接kafka,8102为修改后Kafka的端口号
配置Kafka连接Zookeeper服务的地址
同样在 server.properties
文件中,修改或添加行:
zookeeper.connect=localhost:8101
配置Zookeeper端口
编辑 kafka存放目录/config/zookeeper.properties
修改或添加行:
clientPort=8101
创建Topic
在 kafka存放目录\bin\windows
下执行指令:
kafka-topics.bat --zookeeper 127.0.0.1:8101 --create --topic face_response --partitions 1 --replication-factor 1
其中 --zookeeper
后面指定的是 Zookeeper
服务器地址,--topic
后面指定的是创建的主题名称,--partitions
后面指定的是分区数量,--replication-factor
指定的是副本数量,该参数不能大于 Broker 的数量。