kafka

type Client struct {
	ioc.ObjectImpl

	Username     string   `json:"username" yaml:"username"`
	Password     string   `json:"password" yaml:"password"`
	Brokers      []string `json:"brokers" yaml:"brokers"`
	Async        bool     `json:"async" yaml:"async"`
	BatchTimeout int      `json:"batchTimeout" yaml:"batchTimeout"`
	Offset       int64    `json:"offset" yaml:"offset"`
	// contains filtered or unexported fields
}

type Service interface {
	Producer(topic string) *kafka.Writer
	Consumer(topic, groupId string) *kafka.Reader
}