@Before
	public void createTopic() throws Exception {
		topic1ToUse = "kafka-test-topic-" + random.nextInt();
		// create Kafka topic
		AdminUtils.createTopic(kafkaTestSupport.getZkClient(), topic1ToUse, 1, 1, new Properties());
		setupRetryTemplate(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