Versions in this module Expand all Collapse all v0 v0.2.0 Jul 26, 2022 Changes in this version + const MAX_EARLIEST + type KafkaClient struct + BootstrapServers string + Consumer *kafka.Consumer + TimestampMode string + func NewKafkaClient(options Options) KafkaClient + func (client *KafkaClient) ConsumerPull() (KafkaMessage, kafka.Event) + func (client *KafkaClient) Dispose() + func (client *KafkaClient) TopicAssign(topic string, partition int32, autoOffsetReset string, timestampMode string) + func (client KafkaClient) HealthCheck() error + type KafkaMessage struct + Offset kafka.Offset + Timestamp time.Time + Value map[string]float64 + type Options struct + BootstrapServers string
Go to main page