flink-instrumentation/workspace/flink-1.4.1-instrumented/flink-1.4.1/flink-connectors/flink-connector-kafka-0.8/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/Kafka08PartitionDiscoverer.java
/**
	 * Re-establish broker connection using the next available seed broker address.
	 */
Re-establish broker connection using the next available seed broker address.
Re - establish broker connection using the next available seed broker address .
private void useNextAddressAsNewContactSeedBroker() {
		if (++currentContactSeedBrokerIndex == seedBrokerAddresses.length) {
			currentContactSeedBrokerIndex = 0;
		}
		URL newContactUrl = NetUtils.getCorrectHostnamePort(seedBrokerAddresses[currentContactSeedBrokerIndex]);
		this.consumer = new SimpleConsumer(newContactUrl.getHost(), newContactUrl.getPort(), soTimeout, bufferSize, dummyClientId);
	}
private void useNextAddressAsNewContactSeedBroker ( ) { if ( ++ currentContactSeedBrokerIndex == seedBrokerAddresses . length ) { currentContactSeedBrokerIndex = 0 ; } URL newContactUrl = NetUtils . getCorrectHostnamePort ( seedBrokerAddresses [ currentContactSeedBrokerIndex ] ) ; this . consumer = new SimpleConsumer ( newContactUrl . getHost ( ) , newContactUrl . getPort ( ) , soTimeout , bufferSize , dummyClientId ) ; }
Re-establish broker connection using the next available seed broker address.
Re - establish broker connection using the next available seed broker address .