fix: changed method call in event-sources/sources/kafka/start.go (arg…

…oproj#1457)
icecoffee531 · Dec 9, 2021 · 3626aec · 3626aec
1 parent cdab1e3
commit 3626aec
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