一、下载安装包,我用的是kafka_2.12-2.3.0 百度盘提取https://pan.baidu.com/s/1G8sp9Y5vkIGraZ7vFS1OSw,提取码:15h2。
二、安装
1、解压到:D:\Tools\kafka_2.12-2.3.0 ,其实解压到哪里,依据你的习惯吧,解压位置随便。
2、修改配置文件:D:\Tools\kafka_2.12-2.3.0\config\server.properties
log.dirs=D:\Tools\kafka_2.12-2.3.0\kafka-logs;
解压之后的server.properties 是这样的,
我们要加上面两个配置,如果不加上的话,就会出现:Connection to node 0 could not be established. Broker may not be available.的错误。
listeners=PLAINTEXT://0.0.0.0:9092
advertised.listeners=PLAINTEXT://localhost:9092
3、启动
(1)启动zookeeper,这个在kafka包下已经有的了,不需要再安装了。在目录D:\Tools\kafka_2.12-2.3.0\bin\windows下的地址栏中直接输入cmd回车就可进入命令窗口。
输入:zookeeper-server-start.bat ..\..\config\zookeeper.properties
(2)启动kafka,和上面进入某目录命令窗口操作一样。目录:E:\softinstall\kafka_2.12-2.2.1\bin\windows 执行: kafka-server-start.bat ..\..\config\server.properties
(3)建pp主题,目录:E:\softinstall\kafka_2.12-2.2.1\bin\windows 执行:kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic pp
(4)建消费者,目录:E:\softinstall\kafka_2.12-2.2.1\bin\windows 执行:kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic pp --from-beginning
(5)建生产者,E:\softinstall\kafka_2.12-2.2.1\bin\windows 执行:kafka-console-producer.bat --broker-list localhost:9092 --topic pp
(6)然后在窗口5生产者中输入hello可以在窗口4消费者中看到hello字符。
在springboot中使用KafkaTemplate。
一,在pom.xml中加入kafka包
<dependency>
<groupId>com.gxmis</groupId>
<artifactId>common-kafka</artifactId>
<version>${parent.version}</version>
</dependency>
<dependency>
<groupId>org.apache.kafka</groupId>
<artifactId>kafka-clients</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.kafka</groupId>
<artifactId>spring-kafka</artifactId>
</dependency>
<dependency>
<groupId>com.github.danielwegener</groupId>
<artifactId>logback-kafka-appender</artifactId>
<version>0.2.0-RC2</version>
</dependency>