You are viewing a plain text version of this content. The canonical link for it is here.
Posted to jira@kafka.apache.org by "Kvicii.Yu (Jira)" <ji...@apache.org> on 2022/01/22 08:10:00 UTC

[jira] [Commented] (KAFKA-13606) MirrorCheckpointTask doesn't check offsets sync result

    [ https://issues.apache.org/jira/browse/KAFKA-13606?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17480369#comment-17480369 ] 

Kvicii.Yu commented on KAFKA-13606:
-----------------------------------

hi, [~savulchik] Can you elaborate on how this problem needs to be optimized?

> 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)