kafkat

Documentation

Overview

nolint:gomnd

Index

• type Kafka
  • func NewKafka(t *test.Test) *Kafka
  • func (k *Kafka) Address() string
  • func (k *Kafka) ConsumerConfig(topic, groupId string) kafkax.ConsumerConfig
  • func (k *Kafka) CreateDefaultTopic(topic string)
  • func (k *Kafka) PublisherConfig(topic string) kafkax.PublisherConfig
  • func (k *Kafka) ReadMessage(topic string, offset int64) kafka.Message
  • func (k *Kafka) WriteMessages(msgs ...kafka.Message)

Types

type Kafka

type Kafka struct {
	// contains filtered or unexported fields
}

func NewKafka

func NewKafka(t *test.Test) *Kafka

func (*Kafka) Address

func (k *Kafka) Address() string

func (*Kafka) ConsumerConfig

func (k *Kafka) ConsumerConfig(topic, groupId string) kafkax.ConsumerConfig

func (*Kafka) CreateDefaultTopic

func (k *Kafka) CreateDefaultTopic(topic string)

func (*Kafka) PublisherConfig

func (k *Kafka) PublisherConfig(topic string) kafkax.PublisherConfig

func (*Kafka) ReadMessage

func (k *Kafka) ReadMessage(topic string, offset int64) kafka.Message

func (*Kafka) WriteMessages

func (k *Kafka) WriteMessages(msgs ...kafka.Message)

WriteMessages публикует сообщения в топик, указанный в сообщении