Merge "[FAB-4616] Skip type switch on unmarshaling error"

hyperledger · Jun 14, 2017 · 66655f7 · 66655f7
2 parents 123b3d7 + 9c4cb51
commit 66655f7
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/orderer/kafka/chain.go b/orderer/kafka/chain.go
@@ -233,6 +233,7 @@ func (chain *chainImpl) processMessagesToBlocks() ([]uint64, error) {
 				// This shouldn't happen, it should be filtered at ingress
 				logger.Criticalf("[channel: %s] Unable to unmarshal consumed message = %s", chain.support.ChainID(), err)
 				counts[indexUnmarshalError]++
+				continue
 			} else {
 				logger.Debugf("[channel: %s] Successfully unmarshalled consumed message, offset is %d. Inspecting type...", chain.support.ChainID(), in.Offset)
 				counts[indexRecvPass]++