|
|
|
@ -2183,7 +2183,7 @@ public class FetcherTest {
@@ -2183,7 +2183,7 @@ public class FetcherTest {
|
|
|
|
|
long lastStableOffset, long logStartOffset, int throttleTime) { |
|
|
|
|
Map<TopicPartition, FetchResponse.PartitionData> partitions = Collections.singletonMap(tp, |
|
|
|
|
new FetchResponse.PartitionData(error, hw, lastStableOffset, logStartOffset, null, records)); |
|
|
|
|
return new FetchResponse(new LinkedHashMap<>(partitions), throttleTime); |
|
|
|
|
return new FetchResponse(Errors.NONE, new LinkedHashMap<>(partitions), throttleTime, INVALID_SESSION_ID); |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
private MetadataResponse newMetadataResponse(String topic, Errors error) { |
|
|
|
|