kafka_client

Documentation

Index

• Constants
• type KafkaClient
  • func NewKafkaClient(options Options) KafkaClient
  • func (client *KafkaClient) ConsumerPull() (KafkaMessage, kafka.Event)
  • func (client *KafkaClient) Dispose()
  • func (client KafkaClient) HealthCheck() error
  • func (client *KafkaClient) TopicAssign(topic string, partition int32, autoOffsetReset string, timestampMode string)
• type KafkaMessage
• type Options

Constants

const MAX_EARLIEST int64 = 100

Types

type KafkaClient

type KafkaClient struct {
	Consumer         *kafka.Consumer
	BootstrapServers string
	TimestampMode    string
}

func NewKafkaClient

func NewKafkaClient(options Options) KafkaClient

func (*KafkaClient) ConsumerPull

func (client *KafkaClient) ConsumerPull() (KafkaMessage, kafka.Event)

func (*KafkaClient) Dispose

func (client *KafkaClient) Dispose()

func (KafkaClient) HealthCheck

func (client KafkaClient) HealthCheck() error

func (*KafkaClient) TopicAssign

func (client *KafkaClient) TopicAssign(topic string, partition int32, autoOffsetReset string,
	timestampMode string)

type KafkaMessage

type KafkaMessage struct {
	Value     map[string]float64
	Timestamp time.Time
	Offset    kafka.Offset
}

type Options

type Options struct {
	BootstrapServers string `json:"bootstrapServers"`
}