Hi,
I have a few questions regarding MirrorMaker 2.0.
Q1. Is there JIRA for adding HeartbeatMessageFormatter and
CheckpointMessageFormatter? I want to read messages of the
topic source.checkpoints.internal.
Q2. While running MirrorMaker 2.0, I couldn't find the MBeans
for MirrorCheckpointConnector. There is no error in logs regarding this and
tasks regarding this conector are running fine. I see following messages in
logs:
[2020-06-16 19:06:41,210] INFO
WorkerSourceTask{id=MirrorHeartbeatConnector-0} Finished commitOffsets
successfully in 2 ms
(org.apache.kafka.connect.runtime.WorkerSourceTask:523)[2020-06-16
19:06:41,210] INFO WorkerSourceTask{id=MirrorCheckpointConnector-0}
Committing offsets
(org.apache.kafka.connect.runtime.WorkerSourceTask:424)[2020-06-16
19:06:41,210] INFO WorkerSourceTask{id=MirrorCheckpointConnector-0}
flushing 0 outstanding messages for offset commit
(org.apache.kafka.connect.runtime.WorkerSourceTask:441)
Thanks,
Nitin
