confluent

package

v0.9.2 Latest Latest Go to latest Published: Nov 4, 2025 License: MIT Imports: 2 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type Config struct {
	BootstrapServers string
	GroupId          string
	AutoOffsetReset  string
}

type Consumer struct {
	*kafka.Consumer
	Conf ConsumerConfig
}

func (c *Consumer) Close() error

func (c *Consumer) Config() any

func (c *Consumer) Init() error

type ConsumerConfig kafka.ConfigMap

func (c ConsumerConfig) AfterInject()

func (c ConsumerConfig) BeforeInject()

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

type Producer struct {
	*kafka.Producer
	Conf ProducerConfig
}

func (p *Producer) Close() error

func (p *Producer) Config() any

func (p *Producer) Init() error

type ProducerConfig kafka.ConfigMap

func (c ProducerConfig) AfterInject()

func (c ProducerConfig) BeforeInject()

func (c ProducerConfig) Build() (*kafka.Producer, error)