top
Package go_kafka_client provides a high-level Kafka consumer implementation and introduces different approach than Java/Scala high-level consumer.

Primary differences include workers concept enforcing at least once processing before committing offsets, improved rebalancing algorithm - closing obsolete connections and opening new connections without stopping the whole consumer, graceful shutdown support notifying client when it is over, batch processing, static partitions configuration support allowing to start a consumer with a predefined set of partitions never caring about rebalancing.

Imports 8 package(s) ΒΆ

  1. github.com/stealthly/go-avro
  2. github.com/samuel/go-zookeeper/zk
  3. github.com/stealthly/siesta
  4. github.com/jimlawless/cfg
  5. github.com/Shopify/sarama
  6. github.com/rcrowley/go-metrics
  7. github.com/cihub/seelog
  8. github.com/stealthly/go_kafka_client/avro