Actually enable withRedistributeByRecordKey in KafkaIOTest.

Author: tomstepp

sdks/java/io/kafka/src/test/java/org/apache/beam/sdk/io/kafka/KafkaIOTest.java

@@ -494,6 +494,9 @@ static KafkaIO.Read<Integer, Long> mkKafkaReadTransform(
       if (offsetDeduplication != null && offsetDeduplication) {
         reader.withOffsetDeduplication(offsetDeduplication);
       }
+      if (redistributeByRecordKey != null && redistributeByRecordKey) {
+        reader.withRedistributeByRecordKey(redistributeByRecordKey);
+      }
     }
     return reader;
   }