[
https://issues.apache.org/jira/browse/KAFKA-19410?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18036342#comment-18036342
]
Apoorv Mittal commented on KAFKA-19410:
---------------------------------------
[~yangpoan] Are you inteded to work on it?
> 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: PoAn Yang
> 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)
