3 ms·
An event bus of Kafka internal events. Like „consumer group rebalanced“, „topic created“...
by rad_gruchalski 7y ago
An event bus of Kafka internal events. Like „consumer group rebalanced“, „topic created“...
- EdwardDiego 7y agoAh yep, with you now. While I know you can register a consumer rebalance listener, tools that respond to changes in topic configs seem to do so by polling - e.g., Mirrormaker 2. https://github.com/ryannedolan/kafka/blob/KIP-382/connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorSourceConnector.java https://github.com/ryannedolan/kafka/blob/KIP-382/connect/mi...