This is an automated email from the ASF dual-hosted git repository.
mcvsubbu pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-pinot.git
The following commit(s) were added to refs/heads/master by this push:
new f3b6617 Make Kafka offset out of range as an transient exception.
(#4618)
f3b6617 is described below
commit f3b66177078599bb7504326535bb8140573c2a26
Author: Ting Chen <[email protected]>
AuthorDate: Fri Oct 25 12:50:23 2019 -0700
Make Kafka offset out of range as an transient exception. (#4618)
* Make Kafka offset out of range as an transient exception.
* Update comments.
---
.../apache/pinot/core/realtime/impl/kafka/KafkaConnectionHandler.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git
a/pinot-connectors/pinot-connector-kafka-0.9/src/main/java/org/apache/pinot/core/realtime/impl/kafka/KafkaConnectionHandler.java
b/pinot-connectors/pinot-connector-kafka-0.9/src/main/java/org/apache/pinot/core/realtime/impl/kafka/KafkaConnectionHandler.java
index a3366a3..fe363f8 100644
---
a/pinot-connectors/pinot-connector-kafka-0.9/src/main/java/org/apache/pinot/core/realtime/impl/kafka/KafkaConnectionHandler.java
+++
b/pinot-connectors/pinot-connector-kafka-0.9/src/main/java/org/apache/pinot/core/realtime/impl/kafka/KafkaConnectionHandler.java
@@ -86,7 +86,7 @@ public class KafkaConnectionHandler {
/**
* A Kafka protocol error that indicates a situation that is not likely to
clear up by retrying the request (for
- * example, no such topic or offset out of range).
+ * example, no such topic).
*/
private class KafkaPermanentConsumerException extends RuntimeException {
public KafkaPermanentConsumerException(Errors error) {
@@ -388,7 +388,6 @@ public class KafkaConnectionHandler {
final Errors kafkaError = Errors.forCode(kafkaErrorCode);
switch (kafkaError) {
case UNKNOWN:
- case OFFSET_OUT_OF_RANGE:
case CORRUPT_MESSAGE:
case MESSAGE_TOO_LARGE:
case OFFSET_METADATA_TOO_LARGE:
@@ -402,6 +401,7 @@ public class KafkaConnectionHandler {
case INVALID_SESSION_TIMEOUT:
case INVALID_COMMIT_OFFSET_SIZE:
return new PermanentConsumerException(new
KafkaPermanentConsumerException(kafkaError));
+ case OFFSET_OUT_OF_RANGE:
case UNKNOWN_TOPIC_OR_PARTITION:
case LEADER_NOT_AVAILABLE:
case NOT_LEADER_FOR_PARTITION:
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
