kafka

type KafkaAuthentication struct {
	// values accepted "OAUTHBEARER", "PLAIN", "SCRAM-SHA-256", "SCRAM-SHA-512", "GSSAPI"
	SASLMechanism string `json:"saslmechanism,omitempty"`
	Username      string `json:"username,omitempty"`
	Password      string `json:"password,omitempty"`
}

type KafkaConfiguration struct {
	// Brokers are the Kafka bootstrap brokers to connect to, as a comma separated list
	Brokers string `json:"brokers"`
	// Topic is the Kafka topic to be consumed
	Topic string `json:"topic"`
	// ConsumerGroup is the Kafka consumer group definition
	ConsumerGroup string `json:"consumerGroup"`
	// Kafka cluster version
	Version string `json:"version,omitempty"`
	// Assignor is the Consumer group partition assignment strategy (range, roundrobin, sticky)
	Assignor string `json:"assignor,omitempty"`
	// InitialOffset is the Kafka consumer consume initial offset from oldest
	InitialOffset  string               `json:"offset,omitempty"`
	Authentication *KafkaAuthentication `json:"authentication,omitempty"`
}

type KafkaIngestor struct {
	// below are used to build the Kafka client
	Consumer sarama.ConsumerGroup
	Topic    string
	Brokers  []string
	// contains filtered or unexported fields
}