Skip to content

Commit 6238dc4

Browse files
zzzmingeolivelli
authored andcommitted
lint
1 parent 95e690f commit 6238dc4

File tree

1 file changed

+2
-1
lines changed

1 file changed

+2
-1
lines changed

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

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -964,7 +964,8 @@ protected void handleFetchRequest(KafkaHeaderAndRequest fetch,
964964
log.error("bad error while fetching for {} from {}",
965965
fetchData.keySet(), badError, kopBroker);
966966
fetchData.keySet().forEach(topicPartition ->
967-
errorsConsumer.accept(topicPartition, Errors.FETCH_SESSION_TOPIC_ID_ERROR)
967+
errorsConsumer.accept(topicPartition,
968+
Errors.FETCH_SESSION_TOPIC_ID_ERROR)
968969
);
969970
return null;
970971
}).whenComplete((ignore1, ignore2) -> {

0 commit comments

Comments
 (0)