Tributary.Kafka.Consumer
Attribute-driven Kafka consumer runtime for .NET, built on Akka.NET Streams. Write a single class of [ConsumeTopic<TConfig>]-attributed methods and bootstrap with KafkaHost.CreateDefaultBuilder + AddKafkaConsumer<T>. Supports envelope or raw-DTO handler signatures, optional CancellationToken, startup validation, optional IProcessedEventStore for idempotency, and configurable commit mode (at-least-once or auto-periodic).
Activity
- Latest release
- 3mo ago
- Total releases
- 1
- Cadence
- —
- Last 12 months
- 1
Details
- License
- MIT
- First release
- May 27, 2026
Releases
| Version | Released | |
|---|---|---|
1.0.1
initial
|
1.0.1
initial
Dependencies (9)
+ 1 more |