[
https://issues.apache.org/jira/browse/KAFKA-19410?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
PoAn Yang reassigned KAFKA-19410:
---------------------------------
Assignee: Apoorv Mittal (was: PoAn Yang)
> Validate alignment of subscribed topics and assigned partitions in share
> consumer
> ---------------------------------------------------------------------------------
>
> Key: KAFKA-19410
> URL: https://issues.apache.org/jira/browse/KAFKA-19410
> Project: Kafka
> Issue Type: Sub-task
> Reporter: Andrew Schofield
> Assignee: Apoorv Mittal
> Priority: Major
>
> When a share consumer changes its subscription, this information is flowed to
> the group coordinator in a ShareGroupHeartbeat RPC. In return, the set of
> assigned partitions is received. For a regular consumer when the set of
> subscribed topics is being altered, it has been observed that the consumer
> handles situations in which data is fetched from partitions which do not
> match the current subscription. We should make sure that this area of the
> code is similarly tight, which may require discarding buffered data and
> releasing acquired records.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
