zoo

type ByPartition struct{ Offsets }

type KafkaKeeper struct {
	Consumer *TopicConsumer
	State    *KafkaState
	// contains filtered or unexported fields
}

type KafkaOffsets struct {
	ZookeeperHosts []string
	// ConsumerApp - consumer application get's it's own distinct offsets on the topic
	ConsumerApp string
}

type KafkaState struct {
	Topic string
	// Root - typically blank or "/kafka"
	Root string
}

type Offsets []*PartitionOffset

type PartitionOffset struct {
	Partition int32
	Offset    int64
}

type TopicConsumer struct {
	Topic string
	// ConsumerApp - typically the name of the app or function for it's own dedicated set of offsets
	ConsumerApp string
	// Root - suggested name /kafka-topics
	Root string
}