<Integer, String> consumer.<Integer, String> consumer.Properties object equal to the default consumer property overrides.AdminClient; invoke the callback and reliably close the admin.TestRule wrapper around an EmbeddedKafkaBroker.EmbeddedKafkaBroker instance.DirectFieldAccessors to obtain a property using dotted notation to traverse fields; e.g.KafkaTestUtils.getPropertyValue(Object, String).EmbeddedKafkaBroker.getZooKeeperClient().ConsumerRecord assuming the topic has been set with
CreateTime.ConsumerRecordConditions.Matchers utilities.<Integer, String> producer.<Integer, String> producer.KafkaTestUtils.producerProps(String).