Documentation ¶
Index ¶
- 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
- type Partition
- type Result
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func CreateEarliestConsumer ¶
func CreateEarliestConsumer(bootstrap string, topic string, group string, tracker *progress.Tracker) *kafka.Consumer
CreateEarliestConsumer Creates a new Kafka consumer with the earliest offset
func CreateLatestConsumer ¶
func CreateLatestConsumer(bootstrap string, topic string, group string, tracker *progress.Tracker) *kafka.Consumer
CreateLatestConsumer Creates a new Kafka consumer with the latest offset
Types ¶
type Partition ¶
type Partition struct {
// contains filtered or unexported fields
}
Partition information about a topic partition
type Result ¶
type Result struct { MatchedMessages int64 ReadMessages int64 Duration time.Duration Messages list.List }
Result from a Kafka operation, such as grep or tail
Click to show internal directories.
Click to hide internal directories.