Skip to content

Instantly share code, notes, and snippets.

Created June 25, 2020 21:34
  • Star 0 You must be signed in to star a gist
  • Fork 0 You must be signed in to fork a gist
Star You must be signed in to star a gist
Save tonysneed/d330803e0625c4fb91fc7dd231e6a21d to your computer and use it in GitHub Desktop.
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