HLD of group consumption.

[anuj-flipkart]

Local Region / What happens locally

• Message Consumption. Normal Flow.

• Offset reset to previous point.

1. In MQ

2. In RQ / DLQ

• Offset reset to future point.

1. In MQ
2. In RQ / DLQ

• Group State storage and serving

• Subscription Stop / Start

• Shard count change

Global / Geo Replication. What happens globally

• What are the possible topologies?
  1 -> N. active passive replicated topic. Its not a global topic, but just a replicated one for DR scenarios.

Not tackling:
N -> N. truly global topic. produce anywhere, consume anywhere. No ordering by default.
N -> N. n sets of active passive replicated topic. What is this good for? Cant really provide the ordering post failover like we can give in case of (a).

• Produce Failover.

• Subscription Failover.

[gaurav-ashok]

https://docs.google.com/document/d/1bkXay3JNO7_B6SvJmLcMNyJgJYhAiMV5jw6R6RzhPGo/edit?tab=t.0

[gauravAshok]

Currently exploring the issues due to replication lag in geo-replication.,