fix: index name wrong (#12)

JieTrancender · Aug 22, 2022 · f46266b · f46266b
1 parent c4f3f7d
commit f46266b
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/internal/nsqconsumer/outputs/elasticsearch/client.go b/internal/nsqconsumer/outputs/elasticsearch/client.go
@@ -104,7 +104,7 @@ func (c *Client) Run(msgChan <-chan *message.Message) {
 
 func (c *Client) indexName(topic string) string {
 	now := time.Now()
-	return strftime.Format(fmt.Sprintf("%s-%%&.%%m.%%d", topic), now)
+	return strftime.Format(fmt.Sprintf("%s-%%Y.%%m.%%d", topic), now)
 }
 
 func (c *Client) Publish(msgList []*message.Message) {