Howlett.Kafka.Extensions

Some lightweight abstractions over Confluent.Kafka to make common use cases easy.

What I'm Buildng And Why

Early days! Let's get the ball rolling with:

Stateless Stream Processor

• Specify the input topic and/or output topic and a transform function.
• Can be used for:
  • stateless stream processing.
  • data source.
  • data sink.

example

Async Stream Processor

• 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).

example