diff --git a/service/worker/indexer/processor.go b/service/worker/indexer/processor.go
index 1c9b29d4ab3..db42818723b 100644
--- 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
 	}