kafkautil

package

v0.0.0-...-ffdedf7 Latest Latest Go to latest Published: Aug 1, 2024 License: MIT Imports: 1 Imported by: 0

Details

This section is empty.

This section is empty.

func NewWriter(cfg Config) *kafka.Writer

NewWriter creates a new kafka.Writer. It is the caller's responsibility to close the writer when done.

type Config struct {
	Brokers []string `env:"BROKERS,required" envSeparator:","` // required
}

Config holds Kafka configuration.