...

For Mirror Maker, an internal rebalance listener which implements ConsumerRebalanceCallback is wired in by default to avoid duplicates on consumer rebalance. User could still specify a custom listener class in command line argument. The internal rebalance listener will call that custom listener after it finishes the default logic.

Proposed Changes

Image RemovedImage Added

• No data channel, each mirror maker thread consume messages, process them and then send them.
• Scale by creating more mirror maker thread.

...