教你如何搞定springboot集成kafka
内容提要
本文介绍了如何在本地环境中安装和启动Kafka，包括使用Zookeeper和KRaft两种方式。步骤包括下载Kafka、启动Zookeeper、配置Kafka服务器，以及在Spring Boot中集成Kafka的依赖和配置，示例代码展示了消息的发送和接收。
关键要点
-
Kafka是一种高吞吐量的分布式发布订阅消息系统，依赖Java 8及以上版本。
-
Kafka的启动方式有Zookeeper和KRaft两种，不能同时使用。
-
使用内置Zookeeper启动Kafka时，需先启动Zookeeper，然后启动Kafka。
-
Zookeeper服务器的安装和配置步骤包括下载、解压、修改配置文件和启动服务器。
-
使用KRaft启动Kafka时，需要生成集群UUID并格式化Kafka日志目录。
-
在Spring Boot中集成Kafka时，需要添加spring-kafka依赖，并配置连接信息。
-
生产者通过KafkaTemplate发送消息，消费者使用@KafkaListener接收消息，需配置groupId。
延伸问答
如何在本地环境中安装和启动Kafka？
在本地环境中安装Kafka需要Java 8及以上版本，下载Kafka后，可以选择使用Zookeeper或KRaft启动Kafka。使用Zookeeper时，需先启动Zookeeper，然后再启动Kafka；使用KRaft时，需要生成集群UUID并格式化Kafka日志目录。
Zookeeper和KRaft启动Kafka有什么区别？
Zookeeper和KRaft是两种启动Kafka的方式，不能同时使用。Zookeeper需要先启动Zookeeper服务，然后再启动Kafka，而KRaft则需要生成集群UUID并格式化日志目录后直接启动Kafka。
在Spring Boot中如何集成Kafka？
在Spring Boot中集成Kafka需要添加spring-kafka依赖，并在application.yml中配置连接信息。生产者使用KafkaTemplate发送消息，消费者使用@KafkaListener接收消息，需配置groupId。
Kafka的生产者和消费者是如何工作的？
Kafka的生产者通过KafkaTemplate发送消息，消费者使用@KafkaListener接收消息。消费者需要配置groupId，否则会导致启动失败。
如何配置Zookeeper服务器以启动Kafka？
配置Zookeeper服务器需要下载并解压Zookeeper，修改配置文件zoo.cfg，启动Zookeeper服务器，并确保Kafka的配置文件server.properties正确指向Zookeeper。
Kafka的默认分区数量是多少？
在创建topic时，如果不指定分区数量，Kafka默认会创建1个分区。
