We have three Option structs that store Kafka connection data: KafkaConsumerOperator::Options, KafkaPartitionConsumerBase::Options and KafkaEmitOperator::Options. Despite having separate use cases, they are related in enough to have the common parameters which are used in the same way (e.g. these three classes have a methods called createKafkaConf or createKafkaConsumer in which they create a Kafka connection configuration using similar parameters.) This should simplify maintenance of logic that is common to all three.