configuration

type KafkaConsumerConfig struct {
	BrokerList string `yaml:"broker_list"` // Kafka broker list of Kafka servers (comma separated)
	Topic      string `yaml:"topic"`       // Topic to listen
	Partitions string `yaml:"partitions"`  // Partitions to listen: 'all' or comma separated numbers [0, #P-1]
	Offset     string `yaml:"offset"`      // Offset from which the consumer starts receiving messages
	BufferSize int    `yaml:"buffer_size"` // The consumer message buffer size
	Verbose    bool   `yaml:"verbose"`     // Enable verbose mode on the Kafka API
}

type KafkaProducerConfig struct {
	BrokerList      string `yaml:"broker_list"`      // Kafka broker list of Kafka servers (comma separated)
	ClientId        string `yaml:"client_id"`        // The client's ID
	Topic           string `yaml:"topic"`            // Topic to listen
	Partitioner     string `yaml:"partitioner"`      // Partitioner mode 'random', 'hash' or 'manual'
	Partition       int    `yaml:"partition"`        // Partition to use (ony in 'manual' case)
	CompressionType string `yaml:"compression_type"` // Comppression type: 'compression_none', 'compression_snappy', 'compression_gzip'
	Verbose         bool   `yaml:"verbose"`          // Enable verbose mode on the Kafka API
}