kafka

type Config struct {
	Brokers      []string
	Topic        string
	RequiredAcks sarama.RequiredAcks
	BatchSize    int
	BatchTimeout time.Duration
}

type Publisher[T comparable] struct {
	// contains filtered or unexported fields
}