Skip to content

Instantly share code, notes, and snippets.

Created June 25, 2020 21:34
What would you like to do?
Transform Handler
public class TransformHandler : MessageHandler
public override async Task<Message> HandleMessage(Message sourceMessage)
var message = (Message<int, string>)sourceMessage;
var sinkMessage = new Message<int, string>(message.Key, message.Value.ToUpper());
return await base.HandleMessage(sinkMessage);
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment