kafka

type KafkaConsumerConfig struct {
	*KafkaCredConfig
	GroupID                string
	AutoCommit             bool
	MaxBuffer              int
	AutoCommitIntervalInMs uint64
	EnableLog              bool
}

type KafkaCredConfig struct {
	Brokers       []string
	ServiceName   string
	SASLType      string
	SASLMechanism sasl.Mechanism
	TLSConfig     *tls.Config
}

type KafkaProducerConfig struct {
	*KafkaCredConfig
	Acknowledge            int
	BatchMaxBuffer         int
	BatchFlushIntervalInMs uint64
	Async                  bool
	Batch                  bool
	Topic                  string
	EnableLog              bool
	Name                   string
}

type Message struct {
	*kafka.Message
	// contains filtered or unexported fields
}

type Poller struct {
	*api.Reader
	// contains filtered or unexported fields
}

type Producer struct {
	*api.Writer
	// contains filtered or unexported fields
}