junrao commented on code in PR #14385: URL: https://github.com/apache/kafka/pull/14385#discussion_r1327802559
########## clients/src/main/java/org/apache/kafka/clients/consumer/internals/ConsumerUtils.java: ########## @@ -141,4 +146,53 @@ public static <K, V> List<ConsumerInterceptor<K, V>> configuredConsumerIntercept return (List<ConsumerInterceptor<K, V>>) ClientUtils.configuredInterceptors(config, ConsumerConfig.INTERCEPTOR_CLASSES_CONFIG, ConsumerInterceptor.class); } + /** + * Update subscription state and metadata using the provided committed offsets: + * <li>Update partition offsets with the committed offsets</li> + * <li>Update the metadata with any newer leader epoch discovered in the committed offsets + * metadata</li> + * </p> + * This will ignore any partition included in the <code>offsetsAndMetadata</code> parameter that + * may no longer be assigned. + * + * @param offsetsAndMetadata Committed offsets and metadata to be used for updating the + * subscription state and metadata object. + * @param metadata Metadata object to update with a new leader epoch if discovered in the + * committed offsets' metadata. + * @param subscriptions Subscription state to update, setting partitions' offsets to the + * committed offsets. + * @return False if null <code>offsetsAndMetadata</code> is provided. True in any other case. Review Comment: Will we ever pass in null for offsetsAndMetadata? -- 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