You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pinot.apache.org by mc...@apache.org on 2019/10/25 19:50:34 UTC
[incubator-pinot] branch master updated: Make Kafka offset out of
range as an transient exception. (#4618)
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 <ti...@uber.com>
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: commits-unsubscribe@pinot.apache.org
For additional commands, e-mail: commits-help@pinot.apache.org