Skip to main content

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);  }}