Upstream has spoken on retriable errors

Add InvalidMessage, and re-order the others to match their definition order.
IBM · Jan 2, 2016 · 55f98d5 · 55f98d5
1 parent bb163bf
commit 55f98d5
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/async_producer.go b/async_producer.go
@@ -725,7 +725,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)