KAFKA-6424: QueryableStateIntegrationTest#queryOnRebalance should accept raw text

streams/src/test/java/org/apache/kafka/streams/integration/QueryableStateIntegrationTest.java

@@ -66,7 +66,10 @@
 import org.junit.Test;
 import org.junit.experimental.categories.Category;
 
+import java.io.BufferedReader;
+import java.io.FileReader;
 import java.io.IOException;
+import java.util.ArrayList;
 import java.util.Arrays;
 import java.util.Collections;
 import java.util.Comparator;
@@ -132,6 +135,21 @@ private void createTopics() throws InterruptedException {
         CLUSTER.createTopics(outputTopic, outputTopicConcurrent, outputTopicConcurrentWindowed, outputTopicThree);
     }
 
+    private List<String> readInputValues(String resourceFileName, int headerLinesToSkip) throws Exception {
+        List<String> input = new ArrayList<>();
+        ClassLoader classLoader = getClass().getClassLoader();
+        try (BufferedReader reader = new BufferedReader(new FileReader(classLoader.getResource(resourceFileName).getFile()))) {
+            int linesSkipped = 0;
+            for (String line = reader.readLine(); line != null; line = reader.readLine()) {
+                if (linesSkipped < headerLinesToSkip) {
+                    linesSkipped += 1;
+                } else {
+                    input.add(line);
+                }
+            }
+        }
+        return input;
+    }
 
     @Before
     public void before() throws Exception {
@@ -167,20 +185,7 @@ public int compare(final KeyValue<String, Long> o1,
                 return o1.key.compareTo(o2.key);
             }
         };
-        inputValues = Arrays.asList(
-            "hello world",
-            "all streams lead to kafka",
-            "streams",
-            "kafka streams",
-            "the cat in the hat",
-            "green eggs and ham",
-            "that Sam i am",
-            "up the creek without a paddle",
-            "run forest run",
-            "a tank full of gas",
-            "eat sleep rave repeat",
-            "one jolly sailor",
-            "king of the world");
+        inputValues = readInputValues("data/sampleText.txt", 15);
         inputValuesKeys = new HashSet<>();
         for (final String sentence : inputValues) {
             final String[] words = sentence.split("\\W+");

streams/src/test/resources/data/sampleText.txt

@@ -0,0 +1,28 @@
+Licensed to the Apache Software Foundation (ASF) under one or more
+contributor license agreements. See the NOTICE file distributed with
+this work for additional information regarding copyright ownership.
+The ASF licenses this file to You under the Apache License, Version 2.0
+(the "License"); you may not use this file except in compliance with
+the License. You may obtain a copy of the License at
+
+   http://www.apache.org/licenses/LICENSE-2.0
+
+Unless required by applicable law or agreed to in writing, software
+distributed under the License is distributed on an "AS IS" BASIS,
+WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+See the License for the specific language governing permissions and
+limitations under the License.
+
+hello world
+all streams lead to kafka
+streams
+kafka streams
+the cat in the hat
+green eggs and ham
+that Sam i am
+up the creek without a paddle
+run forest run
+a tank full of gas
+eat sleep rave repeat
+one jolly sailor
+king of the world