kafka-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Manoj Khangaonkar <khangaon...@gmail.com>
Subject Re: Kafka rebalancing message lost
Date Tue, 18 Dec 2018 16:25:23 GMT
Rebalancing of partitions consumers does not necessarily mean loss of

But I understand it can be annoying.

If Kafka is rebalancing between consumers frequently, It means your
consumer code is not polling within the expected timeout, as a result of
Kafka thinks the consumer is gone. You should tune your consumer
implementation to keep the polling loop duration reasonable. See
heartbeat.interval and session.timeout.ms
configuration params in documentation.


On Tue, Dec 18, 2018 at 3:34 AM Parth Gandhi <
parth.gandhi@excellenceinfonet.com> wrote:

> Team,
> We want to build a scalable kafka system for pub sub message and want to
> run consumers (500+) on docker. We want the system to scale up the consumer
> based on the message inflow. However in kafka this triggers a rebalancing
> and we fear loss of message.
> What is the best practices/way to achieve this with no or least message
> failure?
> Disclaimer
> The information contained in this communication from the sender is
> confidential. It is intended solely for use by the recipient and others
> authorized to receive it. If you are not the recipient, you are hereby
> notified that any disclosure, copying, distribution or taking action in
> relation of the contents of this information is strictly prohibited and may
> be unlawful.
> This email has been scanned for viruses and malware, and may have been
> automatically archived by Mimecast Ltd, an innovator in Software as a
> Service (SaaS) for business. Providing a safer and more useful place for
> your human generated data. Specializing in; Security, archiving and
> compliance. To find out more visit the Mimecast website.


  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message