0


【kafka专栏】消费者组数据积压的查看与处理方法

*   [三、数据积压如何处理?](about:blank#_72)

在本专栏前面的文章已经为大家介绍过"消费者"与“消费者”组,在这里有必要回顾一下,并进行更深入的理解。

  • 消费者组是一组具有共同消费特征的消费者的集合,对于kafka来说,这个特征就是这些消费者共同消费一个或几个主题。
  • 消费者组存在的一个重要原因是:单个消费者无法满足某个主题下的数据处理的速度,所以需要多个消费者来负载

每一个消费者组内的消费者都具备一个共享id,即group id(消费者组id)。在创建消费者的时候,设置group id。默认创建消费者的group id是在

KAFKA_HOME/conf/consumer.properties

文件中定义的,默认值是test-consumer-group。

一、主题分区与消费者的数量


在开始为大家介绍消费者之前,有必要深入的了解一下“主题分区数量”与“消费者数量”之间的关系。kafka主题分区消费的一个原则是:一个分区

自我介绍一下,小编13年上海交大毕业,曾经在小公司待过,也去过华为、OPPO等大厂,18年进入阿里一直到现在。

深知大多数Java工程师,想要提升技能,往往是自己摸索成长或者是报班学习,但对于培训机构动则几千的学费,着实压力不小。自己不成体系的自学效果低效又漫长,而且极易碰到天花板技术停滞不前!

因此收集整理了一份《2024年Java

标签: kafka 分布式

本文转载自: https://blog.csdn.net/2301_78399550/article/details/137267787
版权归原作者 柏林的冬 所有, 如有侵权,请联系我们删除。

“【kafka专栏】消费者组数据积压的查看与处理方法”的评论:

还没有评论