kafkadriver

package

v0.1.0 Latest Latest Go to latest Published: Feb 26, 2025 License: GPL-3.0 Imports: 6 Imported by: 0

Details

This section is empty.

View Source

var Config = config.GetConfig().Events.Kafka

View Source

var Driver = new(Kafka)

View Source

var Tracer = otel.Tracer("pkg/kafkadriver")

This section is empty.

type Kafka struct {
	Conn       sarama.SyncProducer
	AuditTopic string
}

func GetDriver() *Kafka

func (k *Kafka) NewClient() *Kafka

Setup Initialize Kafka client

func (k *Kafka) WriteMessage(data interface{}, key string) error