Versions in this module Expand all Collapse all v0 v0.0.2 Sep 5, 2019 Changes in this version + func GetConsumerGroupName(deployment, jobName string, aresCluster string) string + func NewKafkaConsumer(jobConfig *rules.JobConfig, serviceConfig config.ServiceConfig) (consumer.Consumer, error) + type KafkaConsumer struct + CloseAttempted bool + CloseCh chan struct{} + CloseErr error + ErrCh chan error + Logger *zap.Logger + MsgCh chan consumer.Message + Scope tally.Scope + TopicArray []string + func (c *KafkaConsumer) Close() error + func (c *KafkaConsumer) Closed() <-chan struct{} + func (c *KafkaConsumer) CommitUpTo(msg consumer.Message) error + func (c *KafkaConsumer) Errors() <-chan error + func (c *KafkaConsumer) Messages() <-chan consumer.Message + func (c *KafkaConsumer) Name() string + func (c *KafkaConsumer) Topics() []string + type KafkaMessage struct + ClusterName string + Consumer consumer.Consumer + func (m *KafkaMessage) Ack() + func (m *KafkaMessage) Cluster() string + func (m *KafkaMessage) Key() []byte + func (m *KafkaMessage) Nack() + func (m *KafkaMessage) Offset() int64 + func (m *KafkaMessage) Partition() int32 + func (m *KafkaMessage) Topic() string + func (m *KafkaMessage) Value() []byte
Go to main page