Method ManagePartition

offset_manager.go:16–16

ManagePartition creates a PartitionOffsetManager on the given topic/partition. It will return an error if this OffsetManager is already managing the given topic/partition.

(topic string, partition int32)

	// It will return an error if this OffsetManager is already managing the given
	// topic/partition.
	ManagePartition(topic string, partition int32) (PartitionOffsetManager, error)

	// Close stops the OffsetManager from managing offsets. It is required to call
	// this function before an OffsetManager object passes out of scope, as it