kafka2.12 安装
时间: 2023-11-14 21:10:47 浏览: 100
安装Kafka2.12的步骤如下:
1.下载Kafka2.12的二进制包并解压缩到指定目录。
2.修改Kafka配置文件,包括server.properties和zookeeper.properties文件。其中server.properties文件包括broker.id、listeners、log.dirs等参数,zookeeper.properties文件包括dataDir、clientPort等参数。
3.启动Zookeeper服务,使用命令"./zookeeper-server-start.sh -daemon /usr/local/kafka/kafka_2.12-2.1.0/config/zookeeper.properties"。
4.启动Kafka服务,使用命令"./kafka-server-start.sh -daemon /usr/local/kafka/kafka_2.12-2.1.0/config/server.properties"。
5.创建主题,使用命令"kafka-topics.sh --create --zookeeper server01:2181 --replication-factor 1 --partitions 1 --topic test"。
6.启动生产者,使用命令"kafka-console-producer.sh --broker-list server01:9092 --topic test"。
7.启动消费者,使用命令"kafka-console-consumer.sh --bootstrap-server server01:9092 --topic test --from-beginning"。
阅读全文