sarama

package

v0.9.13 Latest Latest Go to latest Published: Dec 2, 2025 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) AfterInject()

func (c *Config) BeforeInject()

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) AfterInject()

func (c *ConsumerConfig) BeforeInject()

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

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) AfterInject()

func (c *ProducerConfig) BeforeInject()

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