jolshan commented on a change in pull request #9944:
URL: https://github.com/apache/kafka/pull/9944#discussion_r603506960
##########
File path:
clients/src/main/java/org/apache/kafka/common/requests/FetchRequest.java
##########
@@ -110,7 +116,68 @@ public String toString() {
}
}
- private Optional<Integer> optionalEpoch(int rawEpochValue) {
+ public static final class UnresolvedPartitions {
+ private final Uuid id;
+ private final Map<Integer, PartitionData> partitionData;
+
+ public UnresolvedPartitions(Uuid id, Map<Integer, PartitionData>
partitionData) {
+ this.id = id;
+ this.partitionData = partitionData;
+ }
+
+ public Uuid id() {
+ return id;
+ }
+
+ public Map<Integer, PartitionData> partitionData() {
+ return partitionData;
+ }
+ }
+
+
+ public static final class FetchDataAndError {
+ private final Map<TopicPartition, PartitionData> fetchData;
+ private final List<UnresolvedPartitions> unresolvedPartitions;
+ private final Map<Uuid, FetchResponse.IdError> idErrors;
+
+ public FetchDataAndError(Map<TopicPartition, PartitionData> fetchData,
List<UnresolvedPartitions> unresolvedPartitions, Map<Uuid,
FetchResponse.IdError> idErrors) {
+ this.fetchData = fetchData;
+ this.unresolvedPartitions = unresolvedPartitions;
+ this.idErrors = idErrors;
+ }
+
+ public final Map<TopicPartition, PartitionData> fetchData() {
+ return fetchData;
+ }
+
+ public final List<UnresolvedPartitions> unresolvedPartitions() {
+ return unresolvedPartitions;
+ }
+
+ public final Map<Uuid, FetchResponse.IdError> idErrors() {
+ return idErrors;
+ }
+ }
+
+ public static final class ToForgetAndIds {
+ private final List<TopicPartition> toForget;
+ private final Map<Uuid, Set<Integer>> toForgetIds;
Review comment:
Removed this object
--
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.
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
