lianetm opened a new pull request, #21253: URL: https://github.com/apache/kafka/pull/21253
When using topic IDs for fetching committed offsets (as of 4.2), there could be a race where a consumer requests offsets to update positions, but unsubscribes from it before receiving a response. In that case, the response to the OffsetFetch will contain a topic ID that the consumer cannot resolve from metadata, failing with Topic does not exist. This PR changes to not fail when receiving committed offsets for a topic that the consumer no longer needs (unsubscribed from it so not in the client metadata). Note that this relates only to the case of fetching offsets to update positions. The manual apis to fetch offsets are not affected by this issue, nor by the change in this PR. Calls to consumer.committed explicitly add topics to metadata as transient topics, so they are not removed from metadata until the response is received and processed. -- 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: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
