flink-instrumentation/workspace/flink-1.4.1-instrumented/flink-1.4.1/flink-connectors/flink-connector-kafka-base/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaConsumerTestBase.java
/**
	 * Variant of {@link KafkaConsumerTestBase#readSequence(StreamExecutionEnvironment, StartupMode, Map, Properties, String, Map)} to
	 * expect reading from the same start offset and the same value count for all partitions of a single Kafka topic.
	 */
Variant of  KafkaConsumerTestBase#readSequence(StreamExecutionEnvironment, StartupMode, Map, Properties, String, Map) to
expect reading from the same start offset and the same value count for all partitions of a single Kafka topic.
Variant of KafkaConsumerTestBase#readSequence ( StreamExecutionEnvironment StartupMode Map Properties String Map ) to expect reading from the same start offset and the same value count for all partitions of a single Kafka topic .
protected void readSequence(final StreamExecutionEnvironment env,
								final StartupMode startupMode,
								final Map<KafkaTopicPartition, Long> specificStartupOffsets,
								final Properties cc,
								final int sourceParallelism,
								final String topicName,
								final int valuesCount,
								final int startFrom) throws Exception {
		HashMap<Integer, Tuple2<Integer, Integer>> partitionsToValuesCountAndStartOffset = new HashMap<>();
		for (int i = 0; i < sourceParallelism; i++) {
			partitionsToValuesCountAndStartOffset.put(i, new Tuple2<>(valuesCount, startFrom));
		}
		readSequence(env, startupMode, specificStartupOffsets, cc, topicName, partitionsToValuesCountAndStartOffset);
	}
protected void readSequence ( final StreamExecutionEnvironment env , final StartupMode startupMode , final Map < KafkaTopicPartition , Long > specificStartupOffsets , final Properties cc , final int sourceParallelism , final String topicName , final int valuesCount , final int startFrom ) throws Exception { HashMap < Integer , Tuple2 < Integer , Integer > > partitionsToValuesCountAndStartOffset = new HashMap < > ( ) ; for ( int i = 0 ; i < sourceParallelism ; i ++ ) { partitionsToValuesCountAndStartOffset . put ( i , new Tuple2 < > ( valuesCount , startFrom ) ) ; } readSequence ( env , startupMode , specificStartupOffsets , cc , topicName , partitionsToValuesCountAndStartOffset ) ; }
Variant of {@link KafkaConsumerTestBase#readSequence(StreamExecutionEnvironment, StartupMode, Map, Properties, String, Map)} to
 expect reading from the same start offset and the same value count for all partitions of a single Kafka topic.
Variant of { @link KafkaConsumerTestBase#readSequence ( StreamExecutionEnvironment StartupMode Map Properties String Map ) } to expect reading from the same start offset and the same value count for all partitions of a single Kafka topic .