You are viewing a plain text version of this content. The canonical link for it is here.
Posted to jira@kafka.apache.org by "Stanislav Savulchik (Jira)" <ji...@apache.org> on 2022/01/21 11:10:00 UTC
[jira] [Updated] (KAFKA-13606) MirrorCheckpointTask doesn't check offsets sync result
[ 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)