apoorvmittal10 commented on code in PR #17870:
URL: https://github.com/apache/kafka/pull/17870#discussion_r1904244877
##########
clients/src/main/java/org/apache/kafka/common/requests/FetchRequest.java:
##########
@@ -59,9 +59,18 @@ public static final class PartitionData {
public final Uuid topicId;
public final long fetchOffset;
public final long logStartOffset;
- public final int maxBytes;
public final Optional<Integer> currentLeaderEpoch;
public final Optional<Integer> lastFetchedEpoch;
+ public int maxBytes;
Review Comment:
Doesn't seems to be a good idea, we need to change the way we create
PartitionData for ShareFetch.
--
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]
