EmbeddedKafkaRule
KafkaTestUtils.consumerProps(String, String, EmbeddedKafkaBroker)
KafkaTestUtils.producerProps(EmbeddedKafkaBroker)