kafka

package

v0.0.21 Latest Latest Go to latest Published: Jul 25, 2024 License: MIT Imports: 1 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

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

func (c *Config) Default()

func (c *Config) Init()

type Consumer struct {
	sarama.Consumer
	Conf ConsumerConfig
}

func (c *Consumer) Close() error

func (c *Consumer) Config() any

func (c *Consumer) Init() error

type ConsumerConfig Config

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

func (c *ConsumerConfig) Init()

func (c *ConsumerConfig) InitBeforeInject()

type Producer struct {
	sarama.SyncProducer
	Conf ProducerConfig
}

func (p *Producer) Close() error

func (p *Producer) Config() any

func (p *Producer) Init() error

type ProducerConfig Config

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

func (c *ProducerConfig) Init()

func (c *ProducerConfig) InitBeforeInject()