首页 > 编程语言 >java——spring boot集成kafka——集群分区消费策略

java——spring boot集成kafka——集群分区消费策略

时间:2023-03-26 15:59:10浏览次数:35  
标签:消费 java 消费者 spring partition boot kafka 集群

 

 

 

 

 

 

 

 

图中Kafka集群有两个broker,每个broker中有多个partition。

 

⼀个partition只能被⼀个消费组⾥的某⼀个消费者消费,从⽽保证消费顺序。

 

Kafka只在partition的范围内保证消息消费的局部顺序性,不能在同⼀个topic中的多个partition中保证总的消费顺序性。

 

⼀个消费者可以消费多个partition。

 

消费组中消费者的数量不能⽐⼀个topic中的partition数量多,否则多出来的消费者消费不到消息。

 

标签:消费,java,消费者,spring,partition,boot,kafka,集群
From: https://www.cnblogs.com/xiaobaibailongma/p/17258791.html

相关文章

  • 10本java书籍,每一本都是经典,从菜鸡到大神
    先来个概览,基本是mobi格式的书籍,不知道怎么打开的小伙伴找我我教你一、设计模式之禅二、你必须知道的261个Java语言问题三、编写高质量代码:改善Java程序的151个建议(......
  • RabbitMQ 04 直连模式-Java操作
    使用Java原生的方式使用RabbitMQ现在已经较少,但这是基础,还是有必要了解的。引入依赖。<dependency><groupId>com.rabbitmq</groupId><artifactId>amqp-clien......
  • RabbitMQ 05 直连模式-Spring Boot操作
    SpringBoot操作SpringBoot集成RabbitMQ是现在主流的操作RabbitMQ的方式。官方文档:https://docs.spring.io/spring-amqp/docs/current/reference/html/引入依赖。<d......
  • SpringBoot2 学习资料,基础篇、实用篇、整合篇、原理篇
    SpringBoot2学习资料,需要的请callme省略好多图片。。。。。。......
  • JAVA面试小结之基础篇
    最近,一直忙于业务,发现自己的很多基础知识没有使用的话,都快忘了,感觉很虚。此外,最近经常面试一些同学,有些东西还得自己复习下,才好意思。这里整理一份JAVA面试小结,一来可以持续......
  • javaSE学习Day1之Object类的使用
    Object类的使用Object类Object类中的方法可以在网上搜索得到Object类是所有java类的父类如果类在声明中未使用extends关键字指明其父类,则默认父类为java.lang.Obje......
  • SpringBoot开发第一篇Idea环境配置
    一、安装JDK下载地址:https://www.oracle.com/java/technologies/downloads/#java8-windows 二、安装maven下载地址:https://maven.apache.org/download.cgi 配置maven......
  • Spring中获取IOC容器中的Bean实例工具封装
    在spring中获取Bean的方式有很多们,这里使用实现ApplicationContextAware接口的方式封装一个可以快速获取Bean实例的方式,具体实现实例: 实现ApplicationContextAware接口......
  • java----内存模型
    内存模型一个对象的内存图方法区开始运行,先找到Main函数,然后将这个方法入栈.new将会在堆空间中开辟空间,里面有成员变量和成员方法(注意,成员方法保存的是方法区的成员......
  • java——spring boot集成kafka——broker、主题、分区、副本——概念理解
    一、代理商Broker 在之前我们已经为大家介绍了生产者向消息队列中投递消息,消费者从消息队列中拉取数据。 在kafka消息队列中有一个非常重要的概念就是代理Broker,大家......