Promote MessageTimedOut to an error that will be retried (#425)

postmates · Mar 1, 2018 · 29a6db5 · 29a6db5
1 parent b572429
commit 29a6db5
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/src/sink/kafka.rs b/src/sink/kafka.rs
@@ -284,6 +284,7 @@ impl Kafka {
                                 | RDKafkaError::NetworkException
                                 | RDKafkaError::GroupLoadInProgress
                                 | RDKafkaError::GroupCoordinatorNotAvailable
+                                | RDKafkaError::MessageTimedOut
                                 | RDKafkaError::NotCoordinatorForGroup
                                 | RDKafkaError::NotEnoughReplicas
                                 | RDKafkaError::NotEnoughReplicasAfterAppend
@@ -515,6 +516,7 @@ mod tests {
             RDKafkaError::NetworkException,
             RDKafkaError::GroupLoadInProgress,
             RDKafkaError::GroupCoordinatorNotAvailable,
+            RDKafkaError::MessageTimedOut,
             RDKafkaError::NotCoordinatorForGroup,
             RDKafkaError::NotEnoughReplicas,
             RDKafkaError::NotEnoughReplicasAfterAppend,