Skip to content

Commit 827d745

Browse files
zzzmingeolivelli
authored andcommitted
address review comments
1 parent 6238dc4 commit 827d745

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

proxy/src/main/java/io/streamnative/pulsar/handlers/kop/KafkaProxyRequestHandler.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -823,7 +823,7 @@ protected void handleFetchRequest(KafkaHeaderAndRequest fetch,
823823
}).exceptionally(badError -> {
824824
log.error("bad error for FULL fetch", badError);
825825
FetchResponse fetchResponse = buildFetchErrorResponse(fetchRequest,
826-
fetchData, Errors.FETCH_SESSION_TOPIC_ID_ERROR);
826+
fetchData, Errors.KAFKA_STORAGE_ERROR);
827827
resultFuture.complete(fetchResponse);
828828
return null;
829829
});
@@ -965,7 +965,7 @@ protected void handleFetchRequest(KafkaHeaderAndRequest fetch,
965965
fetchData.keySet(), badError, kopBroker);
966966
fetchData.keySet().forEach(topicPartition ->
967967
errorsConsumer.accept(topicPartition,
968-
Errors.FETCH_SESSION_TOPIC_ID_ERROR)
968+
Errors.KAFKA_STORAGE_ERROR)
969969
);
970970
return null;
971971
}).whenComplete((ignore1, ignore2) -> {

0 commit comments

Comments
 (0)