hudeqi created KAFKA-15607:
------------------------------
Summary: Possible NPE is thrown in MirrorCheckpointTask
Key: KAFKA-15607
URL: https://issues.apache.org/jira/browse/KAFKA-15607
Project: Kafka
Issue Type: Bug
Components: mirrormaker
Affects Versions: 2.8.1
Reporter: hudeqi
Assignee: hudeqi
In the `syncGroupOffset` method, if `targetConsumerOffset.get(topicPartition)`
gets null, then the calculation of `latestDownstreamOffset` will throw NPE.
This usually occurs in this situation: a group consumed a topic in the target
cluster previously. Later, the group offset of some partitions was reset to -1,
the `OffsetAndMetadata` of these partitions was null.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
