@Override
	public boolean isCapable(Capability capability) {
		switch (capability) {
		case DURABLE_PUBSUB:
		case NATIVE_PARTITIONING:
			return true;
		default:
			return false;
		}
	}
Retry configuration for operations such as validating topic creation
@param retryOperations the retry configuration
spring-xd-messagebus-kafka/src/main/java/org/springframework/xd/dirt/integration/kafka/KafkaMessageBus.java