THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
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<MirrorMakerRecord> handle(MirrorMakerRecord record);}The default message handler just return a list with passed in record.
Changes to make with new consumer
As of now new consumer is still under development. After new consumer is available, the following changes needs to be made:
- Change the message handler interface to take ConsumerRecord for both input and output.
- Change Consumer thread according to new consumer API. The options are:
- Use a single consumer thread. (Preferred unless there is apparent performance issue)
- Use multiple consumer threads by decoupling consumption and processing.
Will submit follow up patch after the new consumer is available.
Compatibility, Deprecation, and Migration Plan
...