The very beginnings of a stream processing layer on top of confluent-kafka-dotnet. Not much here yet.