kafka

package

v0.0.14 Latest Latest Go to latest Published: Mar 2, 2026 License: MIT Imports: 8 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type Client struct {
	// contains filtered or unexported fields
}

func NewKafkaClient(ctx context.Context, opts ...Option) *Client

func (c *Client) Close() error

func (c *Client) CreateTopic(ctx context.Context, topic string, partitions, replication int) error

func (c *Client) DeleteTopics(ctx context.Context, topics ...string) error

func (c *Client) ListTopics() ([]string, error)

func (c *Client) WriteMessages(ctx context.Context, topic string, msg ...kafka.Message) error

type Option func(*Options)

func WithAddress(addr ...string) Option

func WithPlainSASL(userName, password string) Option

func WithSCRAMSASL(userName, password string) Option

func WithTopic(topic string) Option

type Options struct {
	// contains filtered or unexported fields
}

func NewKafkaDialer(opts ...Option) (*kafka.Dialer, *Options)

type Producer struct {
	// contains filtered or unexported fields
}

func NewDefaultProducer(ctx context.Context, opts ...Option) (*Producer, error)

func (p *Producer) Write(ctx context.Context, msg ...kafka.Message) error