[VOL-4663] create voltha event topic (voltha.events) with conifgurable no of partitions and replication factor
Change-Id: I9949f9087c455c9976dad4b1e63be740bb58715f
diff --git a/internal/pkg/core/device_handler.go b/internal/pkg/core/device_handler.go
index b05cd10..fbf2ea7 100755
--- a/internal/pkg/core/device_handler.go
+++ b/internal/pkg/core/device_handler.go
@@ -2859,7 +2859,7 @@
cEventObjectType, cOnuActivatedEvent, "Cleared")
}
/* Send event to KAFKA */
- if err := dh.EventProxy.SendDeviceEvent(ctx, &de, equipment, pon, raisedTs); err != nil {
+ if err := dh.EventProxy.SendDeviceEventWithKey(ctx, &de, equipment, pon, raisedTs, aDeviceID); err != nil {
logger.Warnw(ctx, "could not send ONU_ACTIVATED event",
log.Fields{"device-id": aDeviceID, "error": err})
}