教你如何搞定springboot集成kafka
内容提要
本文介绍了如何在本地环境中安装和启动Kafka，包括使用Zookeeper和KRaft两种方式。步骤包括下载Kafka、启动Zookeeper、配置Kafka服务器，以及在Spring Boot中集成Kafka的依赖和配置，示例代码展示了消息的发送和接收。
延伸解读
Zookeeper 与 KRaft 启动方式的选择
文章指出 Kafka 的启动方式有 Zookeeper 和 KRaft 两种，且不能同时使用。Zookeeper 方式需要先启动 Zookeeper 再启动 Kafka，而 KRaft 方式则需生成集群 UUID 并格式化日志目录。读者应根据自身环境选择一种，避免混用导致启动失败。
Spring Boot 集成 Kafka 的关键配置
集成时需添加 spring-kafka 依赖，并在 application.yml 中配置 bootstrap-servers 指向 Kafka 地址。生产者使用 KafkaTemplate 发送消息，消费者通过 @KafkaListener 接收，且必须指定 groupId，否则会抛出 No group.id found 异常。
本地环境搭建的注意事项
启动 Kafka 本地环境需 Java 8 及以上版本。使用内置 Zookeeper 时，需先启动 Zookeeper 再启动 Kafka；若使用独立 Zookeeper 服务器，则需下载配置并启动 Zookeeper，再启动 Kafka。修改 server.properties 中的 listeners 和 advertised.listeners 可确保外部连接。
Q&A
如何在本地环境中安装和启动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个分区。
