内容提要
本文介绍了如何在本地环境中安装和启动Kafka,包括使用Zookeeper和KRaft两种方式。步骤包括下载Kafka、启动Zookeeper、配置Kafka服务器,以及在Spring Boot中集成Kafka的依赖和配置,示例代码展示了消息的发送和接收。
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个分区。