文章列表
-
- Spring boot 整合KAFKA消息队列的示例
- 这里使用 spring-kafka 依赖和 KafkaTemplate 对象来操作 Kafka 服务。一、添加依赖和添加配置项1.1、在 Pom 文件中添加依赖<dependency> <groupId>org.springframework.kafka</group...
- 日期：2023-08-08
- 浏览：236
- 标签： Spring
-
- Spring Boot集群管理工具KafkaAdminClient使用方法解析
- 原理介绍在Kafka官网中这么描述AdminClient：The AdminClient API supports managing and inspecting topics, brokers, acls, and other Kafka objects. 具体的KafkaAdminClient包...
- 日期：2023-09-20
- 浏览：117
- 标签： Spring
-
- Spring boot集成Kafka消息中间件代码实例
- 一．创建Spring boot项目，添加如下依赖<dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-web...
- 日期：2023-09-05
- 浏览：334
- 标签： Spring
-
- CentOS7上如何安装Kafka?CentOS7上安装Kafka教程
- Kafka 是一种高吞吐的分布式发布订阅消息系统，能够替代传统的消息队列用于解耦合数据处理，缓存未处理消息等。那么CentOS7上如何安装Kafka?下面小编将为大家带来CentOS7上安装Kafka教程！有需要的朋友一起去看看吧
- 日期：2022-06-06
- 浏览：93
-
- Springboot 1.5.7整合Kafka-client代码示例
- 在一次项目中，因甲方需要使用kafka消息队列推送数据，所以需要接入kafka，并且kafka的版本是2.11。但是我们项目使用的是Springboot 1.5.7的版本，对应的springboot.kafka.starter有冲突，所以就接入了kafka-client。Kafka 是一个分布式消息...
- 日期：2023-04-13
- 浏览：54
- 标签： Spring
-
- 使用spring boot 整合kafka,延迟启动消费者
- spring boot 整合kafka,延迟启动消费者spring boot整合kafka的时候一般使用@KafkaListener来设置消费者，但是这种方式在spring启动的时候就会立即开启消费者。如果有需要根据配置信息延迟开启指定的消费者就不能使用这种方式。参考了类：KafkaListener...
- 日期：2023-02-18
- 浏览：228
- 标签： Spring
-
- Java实现Kafka生产者消费者代码实例
- Kafka的结构与RabbitMQ类似，消息生产者向Kafka服务器发送消息，Kafka接收消息后，再投递给消费者。生产者的消费会被发送到Topic中，Topic中保存着各类数据，每一条数据都使用键、值进行保存。每一个Topic中都包含一个或多个物理分区（Partition），分区维护着消息的内容和...
- 日期：2022-09-02
- 浏览：45
- 标签： Java
-
- Java Kafka 消费积压监控的示例代码
- 后端代码：Monitor.java代码：package com.suncreate.kafkaConsumerMonitor.service;import com.suncreate.kafkaConsumerMonitor.model.ConsumerInfo;import org.apache....
- 日期：2022-08-10
- 浏览：50
- 标签： Java
-
- 利用扩展的方式在PHP中使用Kafka的教程分享
- 这篇文章主要为大家详细介绍了如何利用扩展的方式实现在PHP中使用Kafka，具体包括扩展安装和这种方式的基本操作，感兴趣的小伙伴可以跟随小编一起学习一下
- 日期：2022-06-14
- 浏览：46
- 标签： PHP
-
- Apache Kafka 分区重分配的实现原理解析
- 这篇文章主要介绍了Apache Kafka 分区重分配的实现原理,本文结合 2.0.0 版本的 Kafka 源码，详细介绍了 Kafka 分区副本重分配的流程和逻辑，需要的朋友可以参考下
- 日期：2023-03-07
- 浏览：355
网公网安备