@After
	public void deleteTopic() {
		// delete topic
		AdminUtils.deleteTopic(kafkaTestSupport.getZkClient(), topic1ToUse);
	}
Integration tests for Kafka source and sinks.

@author Ilayaperumal Gopinathan
@author Marius Bogoevici
@since 1.1
spring-xd-shell/src/test/java/org/springframework/xd/shell/command/AbstractKafkaSourceSinkTests.java