@Test
	public void kafkaSourceSinkTest() {
		String data = UUID.randomUUID().toString();
		String topic = UUID.randomUUID().toString();
		String sinkStreamName = "ks" + UUID.randomUUID().toString();
		KafkaSource source = sources.kafkaSource().topic(topic).ensureReady();
		KafkaSink sink = sinks.kafkaSink().topic(topic);

		stream(source + XD_DELIMITER + sinks.file());
		stream(sinkStreamName, sources.http() + XD_DELIMITER + sink);
		sources.httpSource(sinkStreamName).postData(data);
		assertFileContains(data);
		assertReceived(1);
	}
Verifies that the data sent via kafka sink can be picked up by the kafka source.
spring-xd-integration-test/src/test/java/org/springframework/xd/integration/test/KafkaTests.java