Skip to content

Latest commit

 

History

History
14 lines (10 loc) · 691 Bytes

offset_storage.md

File metadata and controls

14 lines (10 loc) · 691 Bytes
Raw

Offset storage

go_kafka_client now exposes the OffsetStorage interface to be flexible about managing your offset.

go_kafka_client now also supports Kafka offset storage with Siesta library. To take advantage of this feature you should include the following to your ConsumerConfig:

config := DefaultConsumerConfig()
// your configurations go here
config.OffsetStorage = NewSiestaClient(config)

The default offset storage for now is still Zookeeper though and needs no additional configuration to get it working.