Publishing events to Kafka
Use the IMessenger#
public class EventProducingProcess{ private readonly IMessenger _messenger;
public EventProducingProcess(IMessenger messenger) { _messenger = messenger; }
public async Task Run() { var message = new SomeThingHappenedMessage(); await _messenger.Publish(message, context.ClientContext); }}