• Spring boot 整合KAFKA消息队列的示例
• 这里使用 spring-kafka 依赖和 KafkaTemplate 对象来操作 Kafka 服务。一、添加依赖和添加配置项1.1、在 Pom 文件中添加依赖<dependency> <groupId>org.springframework.kafka</group...
• 日期：2023-08-08
• 浏览：193
• 标签： Spring

---

• spring 整合kafka监听消费的配置过程
• 前言最近项目里有个需求，要消费kafka里的数据。之前也手动写过代码去消费kafka数据。但是转念一想。既然spring提供了消费kafka的方法。就没必要再去重复造轮子。于是尝试使用spring的API。项目技术背景，使用springMVC，XML配置和注解相互使用。kafka的配置都是使用XML...
• 日期：2023-07-20
• 浏览：103
• 标签： Spring

---

---

• SpringBoot集成Kafka的步骤
• SpringBoot集成Kafka本篇主要讲解SpringBoot 如何集成Kafka ，并且简单的 编写了一个Demo 来测试 发送和消费功能前言选择的版本如下：springboot ： 2.3.4.RELEASEspring-kafka ： 2.5.6.RELEASEkafka : 2.5.1z...
• 日期：2023-03-31
• 浏览：19
• 标签： Spring

---

• Spring Boot集群管理工具KafkaAdminClient使用方法解析
• 原理介绍在Kafka官网中这么描述AdminClient：The AdminClient API supports managing and inspecting topics, brokers, acls, and other Kafka objects. 具体的KafkaAdminClient包...
• 日期：2023-09-20
• 浏览：37
• 标签： Spring

---

• Spring boot集成Kafka消息中间件代码实例
• 一．创建Spring boot项目，添加如下依赖<dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-web...
• 日期：2023-09-05
• 浏览：282
• 标签： Spring

---

---

• Spring Boot 集成 Kafkad的实现示例
• Spring Boot 作为主流微服务框架，拥有成熟的社区生态。市场应用广泛，为了方便大家，整理了一个基于spring boot的常用中间件快速集成入门系列手册，涉及RPC、缓存、消息队列、分库分表、注册中心、分布式配置等常用开源组件，大概有几十篇文章，陆续会开放出来，感兴趣同学请提前关注&...
• 日期：2023-07-18
• 浏览：16
• 标签： Spring

---

• Springboot 1.5.7整合Kafka-client代码示例
• 在一次项目中，因甲方需要使用kafka消息队列推送数据，所以需要接入kafka，并且kafka的版本是2.11。但是我们项目使用的是Springboot 1.5.7的版本，对应的springboot.kafka.starter有冲突，所以就接入了kafka-client。Kafka 是一个分布式消息...
• 日期：2023-04-13
• 浏览：21
• 标签： Spring

---

• 使用spring boot 整合kafka,延迟启动消费者
• spring boot 整合kafka,延迟启动消费者spring boot整合kafka的时候一般使用@KafkaListener来设置消费者，但是这种方式在spring启动的时候就会立即开启消费者。如果有需要根据配置信息延迟开启指定的消费者就不能使用这种方式。参考了类：KafkaListener...
• 日期：2023-02-18
• 浏览：186
• 标签： Spring

---

• Java实现Kafka生产者消费者代码实例
• Kafka的结构与RabbitMQ类似，消息生产者向Kafka服务器发送消息，Kafka接收消息后，再投递给消费者。生产者的消费会被发送到Topic中，Topic中保存着各类数据，每一条数据都使用键、值进行保存。每一个Topic中都包含一个或多个物理分区（Partition），分区维护着消息的内容和...
• 日期：2022-09-02
• 浏览：18
• 标签： Java

---

• Kafka Java Producer代码实例详解
• 根据业务需要可以使用Kafka提供的Java Producer API进行产生数据，并将产生的数据发送到Kafka对应Topic的对应分区中，入口类为：ProducerKafka的Producer API主要提供下列三个方法： public void send(KeyedMessage<K,...
• 日期：2022-08-31
• 浏览：156
• 标签： Java

---