Some lightweight abstractions over Confluent.Kafka to make common use cases easy.
Early days! Let's get the ball rolling with:
- Specify the input topic and/or output topic and a transform function.
- Can be used for:
- stateless stream processing.
- data source.
- data sink.