kafka

package

v0.0.0-...-d3f719c Latest Latest Go to latest Published: Jul 23, 2024 License: MIT Imports: 2 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

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

func NewKafkaProducer(ctx context.Context, brokers []string, topic string, log Log) *KafkaProducerImpl

func (kp *KafkaProducerImpl) SendMessage(ctx context.Context, topic string, message []byte) error

type Log interface {
	Info(msg string, keysAndValues ...interface{})
	Error(msg string, err error, keysAndValues ...interface{})
}