Nitin, there is a recently accepted KIP to add the formatters here:
https://cwiki.apache.org/confluence/display/KAFKA/KIP-597%3A+MirrorMaker2+internal+topics+Formatters.
Not
sure if there is a JIRA or PR for the KIP yet.
MirrorCheckpointConnector MBeans won't get created until there are
checkpoints written, which only happens when there are consumer groups to
replicate. Try creating a consumer group that matches the groups whitelist.
Hope that helps!
Ryanne
On Tue, Jun 16, 2020 at 8:45 AM nitin agarwal <nitingarg...@gmail.com>
wrote:
> 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
>
