/go-kit-kafka

Extends go-kit: Kafka transport layer

Primary LanguageGo

go-kit-kafka

WIP

Lightweight channel-based abstraction for Apache Kafka which also supports go kit endpoint integration

Channels supported:

  • Stream
  • Batch
  • PipeStream
  • PipeBatch

For streaming processing use: GOKA

Supported adapters: Sarama