文章列表
-
- Spring boot 整合KAFKA消息队列的示例
- 这里使用 spring-kafka 依赖和 KafkaTemplate 对象来操作 Kafka 服务。一、添加依赖和添加配置项1.1、在 Pom 文件中添加依赖<dependency> <groupId>org.springframework.kafka</group...
- 日期：2023-08-08
- 浏览：207
- 标签： Spring
-
- CentOS7上如何安装Kafka?CentOS7上安装Kafka教程
- Kafka 是一种高吞吐的分布式发布订阅消息系统，能够替代传统的消息队列用于解耦合数据处理，缓存未处理消息等。那么CentOS7上如何安装Kafka?下面小编将为大家带来CentOS7上安装Kafka教程！有需要的朋友一起去看看吧
- 日期：2022-06-06
- 浏览：47
-
- Zabbix对Kafka topic积压数据监控的问题(bug优化)
- 这篇文章主要介绍了Zabbix对Kafka topic积压数据监控,本文给大家介绍的非常详细，对大家的学习或工作具有一定的参考借鉴价值，需要的朋友可以参考下
- 日期：2023-04-06
- 浏览：572
- 标签： Zabbix
-
- Spring Boot集群管理工具KafkaAdminClient使用方法解析
- 原理介绍在Kafka官网中这么描述AdminClient：The AdminClient API supports managing and inspecting topics, brokers, acls, and other Kafka objects. 具体的KafkaAdminClient包...
- 日期：2023-09-20
- 浏览：53
- 标签： Spring
-
- Java实现Kafka生产者消费者代码实例
- Kafka的结构与RabbitMQ类似，消息生产者向Kafka服务器发送消息，Kafka接收消息后，再投递给消费者。生产者的消费会被发送到Topic中，Topic中保存着各类数据，每一条数据都使用键、值进行保存。每一个Topic中都包含一个或多个物理分区（Partition），分区维护着消息的内容和...
- 日期：2022-09-02
- 浏览：26
- 标签： Java
-
- Java kafka如何实现自定义分区类和拦截器
- 生产者发送到对应的分区有以下几种方式：（1）指定了patition，则直接使用；(可以查阅对应的java api, 有多种参数)（2）未指定patition但指定key，通过对key的value进行hash出一个patition；（3）patition和key都未指定，使用轮询选出一个patitio...
- 日期：2022-08-31
- 浏览：28
- 标签： Java
-
- Java实现Kafka生产者和消费者的示例
- Kafka简介Kafka是由Apache软件基金会开发的一个开源流处理平台，由Scala和Java编写。Kafka的目标是为处理实时数据提供一个统一、高吞吐、低延迟的平台。方式一：kafka-clients引入依赖在pom.xml文件中，引入kafka-clients依赖：<dependenc...
- 日期：2022-08-17
- 浏览：212
- 标签： Java
-
- Spring boot集成Kafka消息中间件代码实例
- 一．创建Spring boot项目，添加如下依赖<dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-web...
- 日期：2023-09-05
- 浏览：300
- 标签： Spring
-
- SpringBoot集成Kafka的步骤
- SpringBoot集成Kafka本篇主要讲解SpringBoot 如何集成Kafka ，并且简单的 编写了一个Demo 来测试 发送和消费功能前言选择的版本如下：springboot ： 2.3.4.RELEASEspring-kafka ： 2.5.6.RELEASEkafka : 2.5.1z...
- 日期：2023-03-31
- 浏览：25
- 标签： Spring
-
- Kafka Java Producer代码实例详解
- 根据业务需要可以使用Kafka提供的Java Producer API进行产生数据，并将产生的数据发送到Kafka对应Topic的对应分区中，入口类为：ProducerKafka的Producer API主要提供下列三个方法： public void send(KeyedMessage<K,...
- 日期：2022-08-31
- 浏览：164
- 标签： Java
网公网安备