kafka

Documentation

Index

• type Config
  • func (c *Config) Default()
  • func (c *Config) Init()
• type Consumer
  • func (c *Consumer) Close() error
  • func (c *Consumer) Config() any
  • func (c *Consumer) SetEntity()
• type ConsumerConfig
  • func (c *ConsumerConfig) Build() sarama.Consumer
  • func (c *ConsumerConfig) InitAfterInject()
  • func (c *ConsumerConfig) InitBeforeInject()
• type Producer
  • func (p *Producer) Close() error
  • func (p *Producer) Config() any
  • func (p *Producer) SetEntity()
• type ProducerConfig
  • func (c *ProducerConfig) Build() sarama.SyncProducer
  • func (c *ProducerConfig) InitAfterInject()
  • func (c *ProducerConfig) InitBeforeInject()

Types

type Config

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

func (*Config) Default

func (c *Config) Default()

func (*Config) Init

func (c *Config) Init()

type Consumer

type Consumer struct {
	sarama.Consumer
	Conf ConsumerConfig
}

func (*Consumer) Close

func (c *Consumer) Close() error

func (*Consumer) Config

func (c *Consumer) Config() any

func (*Consumer) SetEntity

func (c *Consumer) SetEntity()

type ConsumerConfig

type ConsumerConfig Config

func (*ConsumerConfig) Build

func (c *ConsumerConfig) Build() sarama.Consumer

func (*ConsumerConfig) InitAfterInject

func (c *ConsumerConfig) InitAfterInject()

func (*ConsumerConfig) InitBeforeInject

func (c *ConsumerConfig) InitBeforeInject()

type Producer

type Producer struct {
	sarama.SyncProducer
	Conf ProducerConfig
}

func (*Producer) Close

func (p *Producer) Close() error

func (*Producer) Config

func (p *Producer) Config() any

func (*Producer) SetEntity

func (p *Producer) SetEntity()

type ProducerConfig

type ProducerConfig Config

func (*ProducerConfig) Build

func (c *ProducerConfig) Build() sarama.SyncProducer

func (*ProducerConfig) InitAfterInject

func (c *ProducerConfig) InitAfterInject()

func (*ProducerConfig) InitBeforeInject

func (c *ProducerConfig) InitBeforeInject()