一、下载安装包,我用的是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 

本地安装kafka和使用

log.dirs=D:\Tools\kafka_2.12-2.3.0\kafka-logs;

本地安装kafka和使用

本地安装kafka和使用

解压之后的server.properties 是这样的,本地安装kafka和使用

  我们要加上面两个配置,如果不加上的话,就会出现: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回车就可进入命令窗口。

本地安装kafka和使用

输入: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字符。

本地安装kafka和使用

在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>

相关文章:

  • 2022-12-23
  • 2021-07-25
  • 2021-06-10
  • 2021-12-09
  • 2022-12-23
  • 2021-09-24
  • 2022-12-23
猜你喜欢
  • 2021-07-19
  • 2021-06-24
  • 2021-05-15
  • 2021-09-04
  • 2021-06-20
  • 2021-09-26
相关资源
相似解决方案