Merge pull request #589 from Shopify/retriable-errors

Upstream has spoken on retriable errors
IBM · Jan 4, 2016 · 2b18ad7 · 2b18ad7
2 parents d7ff2eb + 55f98d5
commit 2b18ad7
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/async_producer.go b/async_producer.go
@@ -727,7 +727,7 @@ func (bp *brokerProducer) handleSuccess(sent *produceSet, response *ProduceRespo
 			}
 			bp.parent.returnSuccesses(msgs)
 		// Retriable errors
-		case ErrUnknownTopicOrPartition, ErrNotLeaderForPartition, ErrLeaderNotAvailable,
+		case ErrInvalidMessage, ErrUnknownTopicOrPartition, ErrLeaderNotAvailable, ErrNotLeaderForPartition,
 			ErrRequestTimedOut, ErrNotEnoughReplicas, ErrNotEnoughReplicasAfterAppend:
 			Logger.Printf("producer/broker/%d state change to [retrying] on %s/%d because %v\n",
 				bp.broker.ID(), topic, partition, block.Err)