网站项目的设计制作,自己做网站,商户网站建设公司,打开官方网站浏览器官网下载 如#xff1a;kafka_2.13-2.4.0.tgz 新版集成了Zookeeper ,无需另行下载 解压 至D:\Kafka\kafka_2.13-2.4.0 下 配置Kafka#xff08;可跳过#xff09; Zookeeper配置 kafka\config\zookeeper.properties下修改dataDir路径(Zookeeper数据目录)dataDirD:\\Program… 官网下载 如kafka_2.13-2.4.0.tgz 新版集成了Zookeeper ,无需另行下载 解压 至D:\Kafka\kafka_2.13-2.4.0 下 配置Kafka可跳过 Zookeeper配置 kafka\config\zookeeper.properties下修改dataDir路径(Zookeeper数据目录)dataDirD:\\ProgramFiles\\kafka\\data\\zookeeperKafka Broker配置 kafka\config\server.properties下指定日志目录log.dirsD:\\ProgramFiles\\kafka\\logs启动服务 运行需要JDK cd .\app\kafka_2.13-3.7.1\bin\windows
# 启动 Zookeeper 服务, 默认端口 2181
.\zookeeper-server-start.bat ..\..\config\zookeeper.properties
# 启动 Kafka 服务,默认端口 9092
.\kafka-server-start.bat ..\..\config\server.properties# 创建 Topic
bin\windows\kafka-topics.bat --create --bootstrap-server localhost:2181 --replication-factor 1 --partitions 1 --topic test
# 该命令 表示创建一个 名为 test 的主题1 个副本1个分区# 启动生产者
bin\windows\kafka-console-producer.bat --broker-list localhost:9092 --topic test
# 启动消费者
bin\windows\kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic test --from-beginning
