lianetm opened a new pull request, #19983: URL: https://github.com/apache/kafka/pull/19983
Fix to ensure assigned partitions whose topics are not in the consumer explicit subscription are considered not fetchable (so that no records are returned on poll for them) This scenario could happen in the new async consumer (using the Consumer rebalance protocol) when the subscription changes, because the consumer will keep its assignment until the coordinator sends a new one (broker drives assignments). This does not happen in the classic consumer because the assignment logic lives on the client-side, so the consumer pro-actively updates assignment as needed. This PR validates assignment vs subscription on fetch for subscription to explicit topic names only Regular expressions, shared subscription remain unchange (regex case still under discussion, will be handled separately if needed) -- 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. To unsubscribe, e-mail: jira-unsubscr...@kafka.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
