@Override
	public void destroy() throws Exception {
		zkClient.close();
	}
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