kafka

Documentation

Index

• type KafkaConfig
• type KafkaConsumer
  • func (c *KafkaConsumer) Close() error
  • func (k *KafkaConsumer) Config() any
  • func (k *KafkaConsumer) SetEntity()
• type KafkaConsumerConfig
  • func (conf *KafkaConsumerConfig) Build() sarama.Consumer
• type KafkaProducer
  • func (c *KafkaProducer) Close() error
  • func (k *KafkaProducer) Config() any
  • func (k *KafkaProducer) SetEntity()
• type KafkaProducerConfig
  • func (conf *KafkaProducerConfig) Build() sarama.SyncProducer

Types

type KafkaConfig

type KafkaConfig struct {
	Addrs []string
	*sarama.Config
}

type KafkaConsumer

type KafkaConsumer struct {
	sarama.Consumer
	Conf KafkaConsumerConfig
}

func (*KafkaConsumer) Close

func (c *KafkaConsumer) Close() error

func (*KafkaConsumer) Config

func (k *KafkaConsumer) Config() any

func (*KafkaConsumer) SetEntity

func (k *KafkaConsumer) SetEntity()

type KafkaConsumerConfig

type KafkaConsumerConfig KafkaConfig

func (*KafkaConsumerConfig) Build

func (conf *KafkaConsumerConfig) Build() sarama.Consumer

type KafkaProducer

type KafkaProducer struct {
	sarama.SyncProducer
	Conf KafkaProducerConfig
}

func (*KafkaProducer) Close

func (c *KafkaProducer) Close() error

func (*KafkaProducer) Config

func (k *KafkaProducer) Config() any

func (*KafkaProducer) SetEntity

func (k *KafkaProducer) SetEntity()

type KafkaProducerConfig

type KafkaProducerConfig KafkaConfig

func (*KafkaProducerConfig) Build

func (conf *KafkaProducerConfig) Build() sarama.SyncProducer