Versions Compared

Old Version 9

changes.mady.by.user Jiangjie Qin

Saved on

compared with

New Version 10

changes.mady.by.user Jiangjie Qin

Saved on

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.

...

public interface MirrorMakerMessageHandler {
    /**
     * The message handler will be executed to handle messages in mirror maker
     * consumer thread before the messages go into data channel. The message handler should
     * not block and should handle all the exceptions by itself.
     */
    public List<ConsumerRecord> List<MirrorMakerRecord> handle(ConsumerRecord MirrorMakerRecord record);
}
The default message handler just return a list with passed in record.

...