Add missing nack

cadence-workflow · Aug 26, 2020 · 843ea61 · 843ea61
1 parent e3aea20
commit 843ea61
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/service/worker/indexer/processor.go b/service/worker/indexer/processor.go
@@ -200,6 +200,7 @@ func (p *indexProcessor) addMessageToES(indexMsg *indexer.Message, kafkaMsg mess
 			tag.WorkflowDomainID(indexMsg.GetDomainID()),
 			tag.WorkflowID(indexMsg.GetWorkflowID()),
 			tag.WorkflowRunID(indexMsg.GetRunID()))
+		kafkaMsg.Nack()
 		return nil
 	}