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.
- Apply async functions to input messages.
- Manage many simultaneously executing tasks.
- Specify output order as input order or task completion order.
- Use as a processor, filter or sink (not yet source).