consumer

type ConsumerInput struct {
	// KafkaBrokers is a string of addresses of Kafka broker systems
	KafkaBrokers      []string
	KafkaVersion      sarama.KafkaVersion
	KafkaTopic        string
	KafkaProtoSchema  proto.Message
	KafkaLogErrors    bool
	MsgDelimitWithLen bool
}

type KafkaConsumer struct {
	// contains filtered or unexported fields
}