root
/
kafka
mirror of https://github.com/apache/kafka.git
1
0
Fork 0
Code Issues Actions 2 Packages Projects Releases Wiki Activity

Update AsyncKafkaConsumer.java

This commit is contained in:
Kirk True 2025-10-07 08:57:08 -07:00
parent 68f5bc19d3
commit 5215030a4c
1 changed files with 0 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AsyncKafkaConsumer.java
View File

@ -1829,9 +1829,6 @@ public class AsyncKafkaConsumer<K, V> implements ConsumerDelegate<K, V> {
// We do not want to be stuck blocking in poll if we are missing some positions // We do not want to be stuck blocking in poll if we are missing some positions
// since the offset lookup may be backing off after a failure // since the offset lookup may be backing off after a failure
// NOTE: the use of cachedSubscriptionHasAllFetchPositions means we MUST call
// updateAssignmentMetadataIfNeeded before this method.
if (pollTimeout > retryBackoffMs) { if (pollTimeout > retryBackoffMs) {
pollTimeout = retryBackoffMs; pollTimeout = retryBackoffMs;
} }