public static KafkaSource withDefaults() {
		return new KafkaSource(DEFAULT_ZK_CLIENT);
	}
Returns an instance of the KafkaSource using defaults.

@return instance of the KafkaSource
spring-xd-test-fixtures/src/main/java/org/springframework/xd/test/fixtures/KafkaSource.java