View definition

type PartitionOffsetManager

Defined in github.com/Shopify/sarama/offset_manager.go

Description

PartitionOffsetManager uses Kafka to store and fetch consumed partition offsets. You MUST call Close() on a partition offset manager to avoid leaks, it will not be garbage-collected automatically when it passes out of scope.

PartitionOffsetManager is referenced in 1 repository

github.com/Shopify/sarama