文章列表
-
- Spring boot集成Kafka消息中间件代码实例
- 一.创建Spring boot项目,添加如下依赖<dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-web...
- 日期:2023-09-05
- 浏览:46
- 标签: Spring
-
- spring 整合kafka监听消费的配置过程
- 前言最近项目里有个需求,要消费kafka里的数据。之前也手动写过代码去消费kafka数据。但是转念一想。既然spring提供了消费kafka的方法。就没必要再去重复造轮子。于是尝试使用spring的API。项目技术背景,使用springMVC,XML配置和注解相互使用。kafka的配置都是使用XML...
- 日期:2023-07-20
- 浏览:22
- 标签: Spring
-
- java自己手动控制kafka的offset操作
- 之前使用kafka的KafkaStream,让每个消费者和对应的patition建立对应的流来读取kafka上面的数据,如果comsumer得到数据,那么kafka就会自动去维护该comsumer的offset,例如在获取到kafka的消息后正准备入库(未入库),但是消费者挂了,那么如果让kafka...
- 日期:2022-08-16
- 浏览:44
- 标签: Java
-
- 利用扩展的方式在PHP中使用Kafka的教程分享
- 这篇文章主要为大家详细介绍了如何利用扩展的方式实现在PHP中使用Kafka,具体包括扩展安装和这种方式的基本操作,感兴趣的小伙伴可以跟随小编一起学习一下
- 日期:2022-06-14
- 浏览:3
- 标签: PHP
-
- Springboot 1.5.7整合Kafka-client代码示例
- 在一次项目中,因甲方需要使用kafka消息队列推送数据,所以需要接入kafka,并且kafka的版本是2.11。但是我们项目使用的是Springboot 1.5.7的版本,对应的springboot.kafka.starter有冲突,所以就接入了kafka-client。Kafka 是一个分布式消息...
- 日期:2023-04-13
- 浏览:2
- 标签: Spring
-
- Java实现Kafka生产者消费者代码实例
- Kafka的结构与RabbitMQ类似,消息生产者向Kafka服务器发送消息,Kafka接收消息后,再投递给消费者。生产者的消费会被发送到Topic中,Topic中保存着各类数据,每一条数据都使用键、值进行保存。每一个Topic中都包含一个或多个物理分区(Partition),分区维护着消息的内容和...
- 日期:2022-09-02
- 浏览:3
- 标签: Java
-
- Kafka Java Producer代码实例详解
- 根据业务需要可以使用Kafka提供的Java Producer API进行产生数据,并将产生的数据发送到Kafka对应Topic的对应分区中,入口类为:ProducerKafka的Producer API主要提供下列三个方法: public void send(KeyedMessage<K,...
- 日期:2022-08-31
- 浏览:32
- 标签: Java
-
- Java kafka如何实现自定义分区类和拦截器
- 生产者发送到对应的分区有以下几种方式:(1)指定了patition,则直接使用;(可以查阅对应的java api, 有多种参数)(2)未指定patition但指定key,通过对key的value进行hash出一个patition;(3)patition和key都未指定,使用轮询选出一个patitio...
- 日期:2022-08-31
- 浏览:8
- 标签: Java
-
- CentOS7上如何安装Kafka?CentOS7上安装Kafka教程
- Kafka 是一种高吞吐的分布式发布订阅消息系统,能够替代传统的消息队列用于解耦合数据处理,缓存未处理消息等。那么CentOS7上如何安装Kafka?下面小编将为大家带来CentOS7上安装Kafka教程!有需要的朋友一起去看看吧
- 日期:2022-06-06
- 浏览:87
-
- Zabbix对Kafka topic积压数据监控的解决方案
- 这篇文章主要介绍了Zabbix对Kafka topic积压数据监控的解决方案,它与Apache Storm和Spark非常好地集成,用于实时流式数据分析,需要的朋友跟随小编一起看看吧
- 日期:2023-04-06
- 浏览:107
- 标签: Zabbix