kafka

package

v0.0.0-...-855f182 Latest Latest Go to latest Published: Feb 20, 2023 License: MIT Imports: 4 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type Config struct {
	Brokers   []string
	Topic     string
	Group     string
	Partition int
}

type EasyKafka struct {
	Logf func(string, ...interface{})
	// contains filtered or unexported fields
}

func NewEasyKafka(xLog *xlog.XLog) *EasyKafka

func (easy *EasyKafka) Read(c *Config, ch chan *kafka.Message)

func (easy *EasyKafka) Write(c Config, ch chan []*kafka.Message, resp chan []*kafka.Message)

func (easy *EasyKafka) WriteBatch(c *Config, ch chan []*kafka.Message, resp chan []*kafka.Message)