C0urante commented on a change in pull request #11046:
URL: https://github.com/apache/kafka/pull/11046#discussion_r764381476
##########
File path:
clients/src/main/java/org/apache/kafka/clients/consumer/internals/Fetcher.java
##########
@@ -725,17 +725,13 @@ public void onFailure(RuntimeException e) {
completedFetch.nextFetchOffset,
completedFetch.lastEpoch,
position.currentLeader);
- log.trace("Update fetching position to {} for partition
{}", nextPosition, completedFetch.partition);
+ log.trace("Updating fetch position from {} to {} for
partition {} and returning {} records from `poll()`",
+ position, nextPosition, completedFetch.partition,
partRecords.size());
subscriptions.position(completedFetch.partition,
nextPosition);
positionAdvanced = true;
if (partRecords.isEmpty()) {
- log.debug(
- "Advanced position for partition {} without
receiving any user-visible records. "
- + "This is likely due to skipping over
control records in the current fetch, "
- + "and may result in the consumer
returning an empty record batch when "
- + "polled before its poll timeout has
elapsed.",
- completedFetch.partition
- );
+ log.trace("Returning empty records from `poll()` "
+ + "since the consumer's position has advanced
for at least one topic partition");
Review comment:
Moved it to `KafkaConsumer`.
--
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]
