@kafkalistener

加载中

@KafkaListener和@KafkaListeners的使用

https://my.oschina.net/u/4301916/blog/3348359

正文前先来一波福利推荐: 福利一: 百万年薪架构师视频,该视频可以学到很多东西,是本人花钱买的VIP课程,学习消化了一年,为了支持一下女朋友公众号也方便大家学习,共享给大家。 福利二:...

2019/11/13 00:00

spring-kafka之KafkaListener注解深入解读

https://my.oschina.net/u/4288530/blog/4295939

简介 Kafka目前主要作为一个分布式的发布订阅式的消息系统使用,也是目前最流行的消息队列系统之一。因此,也越来越多的框架对kafka做了集成,比如本文将要说到的spring-kafka。 Kafka既然作...

2020/05/30 00:00

使用KafkaListener 监听消费数据时重复消费

https://www.oschina.net/question/3654234_2290645

各位同学好,我最近使用使用KafkaListener 监听消费数据时候发现,如果我开2个程序,发现2个程序都能消费到数据。且2个程序的groupid相同。正常情况下,相同groupid的话,应该只有一个用户可...

2018/12/13 00:00

Spring for Apache Kafka @KafkaListener使用及注意事项

https://my.oschina.net/u/4277479/blog/3525225

官方文档: https://docs.spring.io/spring-kafka/reference/html/ The annotation is used to designate a bean method as a listener for a listener container. The bean is wrapped in a ...

2019/05/24 00:00

Spring Boot 中使用@KafkaListener批量接收消息ack

https://my.oschina.net/u/866802/blog/1812047

之前介绍了如何在SpringBoot中集成Kafka,但是默认情况下,@KafkaListener都是一条一条消费,如果想要一次消费一个批量的话,我们都知道,在kafka原生的API可以通过poll(num)来获取一次获取n...

2018/05/14 00:00

springboot + @KafkaListener 手动提交及消费能力优化

https://my.oschina.net/u/4411698/blog/3682897

转载 https://blog.csdn.net/asd5629626/article/details/82776450 https://blog.csdn.net/asd5629626/article/details/82746771 spring-boot 版本 1.5.12 依赖使用spring-kafka1.3.3(对应k...

2019/01/09 00:00

spring kafka之如何批量给topic加前缀

https://my.oschina.net/u/4494662/blog/4775643

前言 最近业务开发部门给我们部门提了一个需求,因为他们开发环境和测试环境共用一套kafka,他们希望我们部门能帮他们实现自动给kafka的topic加上环境前缀,比如开发环境,则topic为devtopi...

2020/12/05 00:00

Springboot中使用kafka

https://my.oschina.net/u/4263469/blog/3617798

注:kafka消息队列默认采用配置消息主题进行消费,一个topic中的消息只能被同一个组(groupId)的消费者中的一个消费者消费。 1.在pom.xml依赖下新添加一下kafka依赖ar包 org.springframewor...

2019/03/12 00:00

Springboot系列之kafka操作

https://my.oschina.net/u/3138152/blog/3096290

Springboot系列之kafka操作(https://ailijie.top/archives/kafka) kafka简介 ApacheKafka®是一个分布式流媒体平台。有三个关键功能: 发布和订阅记录流,类似于消息队列或企业消息传递系统。...

2019/08/22 00:00

Spring 对Apache Kafka的支持与集成

https://my.oschina.net/u/2772398/blog/4750894

1. 引言 Apache Kafka 是一个分布式的、容错的流处理系统。在本文中,我们将介绍Spring对Apache Kafka的支持,以及原生Kafka Java客户端Api 所提供的抽象级别。 Spring Kafka 通过 @KafkaLi...

2020/11/26 00:00

Spring Kafka - Spring 的 Kafka 抽象

https://www.oschina.net/p/spring-kafka

Spring for Apache Kafka (spring-kafka) 项目将 Spring 核心概念应用于基于 Kafka 的消息传递解决方案的开发。它提供了一个“模板”作为发送消息的高级抽象。它还通过 @KafkaListener 注解和...

同一个工程消费多个kafka集群的多个topic

https://www.oschina.net/question/2504277_2284985

同一个工程消费多个kafka集群的多个topic 手动根据配置实例KafkaListenerContainerFactory 然后一个kafka集群用 一个KafkaListener注解来处理消息,在方法里在根据当前消息的topic name判断 ...

2018/08/14 00:00

Spring Kafka

https://my.oschina.net/u/4290481/blog/3373881

在Spring中应用Kafka及配置 1、需要的jar包 兼容:   • Apache Kafka Clients 2.0.0   • Spring Framework 5.1.x   • Minimum Java version: 8 2、Kafka配置类 import org.apache....

2019/10/12 00:00

Spring Boot 自定义kafka 消费者配置 ContainerFactory最佳实践

https://my.oschina.net/u/4364002/blog/4255088

Spring Boot 自定义kafka 消费者配置 ContainerFactory最佳实践 本篇博文主要提供一个在 SpringBoot 中自定义 kafka配置的实践,想象这样一个场景:你的系统需要监听多个不同集群的消息,在不...

2020/04/27 00:00

SpringBoot+Kafka实现单条或批量消费

https://my.oschina.net/u/2404202/blog/2051313

依赖 配置文件 配置 生产者 消费者

2018/09/14 00:00

spring boot集成kafka之spring-kafka深入探秘

https://my.oschina.net/u/4074104/blog/3056698

前言 kafka是一个消息队列产品,基于Topic partitions的设计,能达到非常高的消息发送处理性能。Spring创建了一个项目Spring-kafka,封装了Apache 的Kafka-client,用于在Spring项目里快速集...

2019/05/31 00:00

spring boot集成kafka之spring-kafka深入探秘 前言 简单集成 Spring-kafka-test嵌入式Kafka Server 创建新的Topic 消息发送之Kafka...

https://my.oschina.net/u/2746801/blog/4831238

前言 kafka是一个消息队列产品,基于Topic partitions的设计,能达到非常高的消息发送处理性能。Spring创建了一个项目Spring-kafka,封装了Apache 的Kafka-client,用于在Spring项目里快速集...

2019/05/31 00:00

mysql数据压缩方案,windows 安装kafaka:

https://my.oschina.net/u/3971821/blog/4447301

mysql数据压缩方案,windows 安装kafaka: https://developer.aliyun.com/article/64891 https://www.cnblogs.com/mysql-dba/p/5125220.html 列压缩就是压缩某一列,表压缩就是压缩所有列。压...

2020/07/28 00:00

Spring Boot Kafka概览、配置及优雅地实现发布订阅

https://my.oschina.net/u/3853586/blog/3147524

本文属于原创,转载注明出处,欢迎关注微信小程序 微信公众号或者网站 https://xiaobaiai.net [TOC] 1 前言 本篇文章内容很全,很长,很细!不要心急,慢慢看!我都写完了,相信你看完肯定可...

2019/12/26 00:00

kafka 暂停消费

https://my.oschina.net/u/4393789/blog/3789961

1、代码实现 kafkaListener 需要指定id,例如这里是:full-part-id。 @KafkaListener(topics = "part-full-topic", id = "full-part-id", containerGroup = "full-part-group")public void l...

2018/10/16 00:00
返回顶部
顶部