[ https://issues.apache.org/jira/browse/KAFKA-13606?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Stanislav Savulchik updated KAFKA-13606: ---------------------------------------- Description: {{MirrorCheckpointTask}} doesn't check the result of calling {{AdminClient#alterConsumerGroupOffsets}} method that could return a failed Future for instance due to incorrect ACL in the target kafka cluster. [https://github.com/apache/kafka/blob/3.0.0/connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorCheckpointTask.java#L302] I guess it should at least log or even rethrow the exception. was: {{MirrorCheckpointTask}} doesn't check the result of calling {{AdminClient#alterConsumerGroupOffsets}} method that could return a failed Future for instance due to incorrect ACL in the target kafka cluster. [https://github.com/apache/kafka/blob/3.0.0/connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorCheckpointTask.java#L302] > MirrorCheckpointTask doesn't check offsets sync result > ------------------------------------------------------ > > Key: KAFKA-13606 > URL: https://issues.apache.org/jira/browse/KAFKA-13606 > Project: Kafka > Issue Type: Bug > Components: mirrormaker > Affects Versions: 2.7.0, 2.8.0, 2.7.1, 2.7.2, 2.8.1, 3.0.0 > Reporter: Stanislav Savulchik > Priority: Major > > {{MirrorCheckpointTask}} doesn't check the result of calling > {{AdminClient#alterConsumerGroupOffsets}} method that could return a failed > Future for instance due to incorrect ACL in the target kafka cluster. > [https://github.com/apache/kafka/blob/3.0.0/connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorCheckpointTask.java#L302] > I guess it should at least log or even rethrow the exception. -- This message was sent by Atlassian Jira (v8.20.1#820001)