fix: changed method call in event-sources/sources/kafka/start.go (#1457)

argoproj · Dec 9, 2021 · 6f0d4fc · 6f0d4fc
1 parent 76777a7
commit 6f0d4fc
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/eventsources/sources/kafka/start.go b/eventsources/sources/kafka/start.go
@@ -233,7 +233,7 @@ func (el *EventListener) partitionConsumer(ctx context.Context, log *zap.Sugared
 
 		kafkaID := genUniqueID(el.GetEventSourceName(), el.GetEventName(), kafkaEventSource.URL, msg.Topic, msg.Partition, msg.Offset)
 
-		if err = dispatch(eventBody, eventsourcecommon.SetCustomID(kafkaID)); err != nil {
+		if err = dispatch(eventBody, eventsourcecommon.WithID(kafkaID)); err != nil {
 			return errors.Wrap(err, "failed to dispatch a Kafka event...")
 		}
 		return nil