Use message.Key instead of message.Topic

Trendyol · Dec 27, 2024 · 81f6905 · 81f6905
1 parent 0c85b77
commit 81f6905
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/execution_behaviour/behavioral/retry_execute_behavioral.go b/execution_behaviour/behavioral/retry_execute_behavioral.go
@@ -48,7 +48,7 @@ func (k *retryBehaviour) Process(ctx context.Context, message *sarama.ConsumerMe
 
 		err = k.executor.Operate(ctx, message)
 		if err == nil {
-			fmt.Printf("Message is executed successfully, message topic: %+v\n", message.Topic)
+			fmt.Printf("Message is executed successfully, message key: %+v\n", message.Key)
 			break
 		}
 	}