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