You are viewing a plain text version of this content. The canonical link for it is here.
Posted to jira@kafka.apache.org by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2020/03/21 01:30:00 UTC
[jira] [Commented] (KAFKA-9741) ConsumerCoordinator must update
ConsumerGroupMetadata before calling onPartitionsRevoked()
[ https://issues.apache.org/jira/browse/KAFKA-9741?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17063708#comment-17063708 ]
ASF GitHub Bot commented on KAFKA-9741:
---------------------------------------
mjsax commented on pull request #8325: KAFKA-9741: Update ConsumerGroupMetadata before calling onPartitionsRevoked()
URL: https://github.com/apache/kafka/pull/8325
If partitions are revoked, an application may want to commit the current offsets.
Using transactions, committing offsets would be done via the producer passing in the current `ConsumerGroupMetadata`. If the metadata is not updates before the callback, the call to `commitTransaction(...)` fails as and old generationId would be used.
Call for review @ableegoldman @abbccdda @guozhangwang @hachikuji
\cc @mumrah (not sure if this is a blocker for 2.5 or not)
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
> ConsumerCoordinator must update ConsumerGroupMetadata before calling onPartitionsRevoked()
> ------------------------------------------------------------------------------------------
>
> Key: KAFKA-9741
> URL: https://issues.apache.org/jira/browse/KAFKA-9741
> Project: Kafka
> Issue Type: Bug
> Components: consumer
> Affects Versions: 2.5.0
> Reporter: Matthias J. Sax
> Assignee: Matthias J. Sax
> Priority: Critical
>
> If partitions are revoked, an application may want to commit the current offsets.
> Using transactions, committing offsets would be done via the producer passing in the current `ConsumerGroupMetadata`. If the metadata is not updates before the callback, the call to `commitTransaction(...)` fails as and old generationId would be used.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)