Method ConsumePartition

consumer.go:68–68

ConsumePartition creates a PartitionConsumer on the given topic/partition with the given offset. It will return an error if this Consumer is already consuming on the given topic/partition. Offset can be a literal offset, or OffsetNewest or OffsetOldest

(topic string, partition int32, offset int64)

	// on the given topic/partition. Offset can be a literal offset, or OffsetNewest
	// or OffsetOldest
	ConsumePartition(topic string, partition int32, offset int64) (PartitionConsumer, error)

	// HighWaterMarks returns the current high water marks for each topic and partition.
	// Consistency between partitions is not guaranteed since high water marks are updated separately.