Details
-
Improvement
-
Status: Resolved
-
Trivial
-
Resolution: Fixed
-
None
-
None
-
Patch
Description
Previously, message for `message.handler` was simply copy-pasted from `"consumer.rebalance.listener`: https://github.com/apache/kafka/blob/trunk/core/src/main/scala/kafka/tools/MirrorMaker.scala#L122