HF RL Explorer

Issue: KafkaCanalConnector lacks HA support with leader election

Issue: KafkaCanalConnector lacks HA support with leader election: a task in LegoFlow-SWE (Harbor dataset). The canal-kafka-client does not currently support high availability (HA) cluster deployments. When multiple KafkaCanalConnector instances are started with the same topic and groupId, they all…

The task

The canal-kafka-client does not currently support high availability (HA) cluster deployments. When multiple `KafkaCanalConnector` instances are started with the same topic and groupId, they all consume messages independently, causing duplicate processing and contention.

Part of Lego-X/LegoFlow-SWE.