Versions in this module Expand all Collapse all v0 v0.1.0 Dec 6, 2020 Changes in this version + func CreateEarliestConsumer(bootstrap string, topic string, group string, tracker *progress.Tracker) *kafka.Consumer + func CreateLatestConsumer(bootstrap string, topic string, group string, tracker *progress.Tracker) *kafka.Consumer + func GetPartitions(consumer *kafka.Consumer, topic string, tracker *progress.Tracker) map[int32]Partition + func StopConsumer(consumer *kafka.Consumer, tracker *progress.Tracker) + type Message struct + Key string + Offset string + Partition int32 + Timestamp time.Time + Value string + type Partition struct + type Result struct + Duration time.Duration + MatchedMessages int64 + Messages list.List + ReadMessages int64 + func Consume(consumer *kafka.Consumer, partitions map[int32]Partition, topic string, ...) Result + func Tail(consumer *kafka.Consumer, keyQuery string, valueQuery string, limit int64, ...) Result