MINOR: fixing streams test-util compilation errors in Eclipse
Author: Edoardo Comar
Reviewer: Matthias J. Sax
@@ -178,7 +178,7 @@ public class ConsumerRecordFactoryTest {
}
final List<ConsumerRecord<byte[], byte[]>> records =
- factory.create(Arrays.<KeyValue<String, Long>>asList(keyValuePairs));
+ factory.create(Arrays.<KeyValue<String, Integer>>asList(keyValuePairs));
for (int i = 0; i < keyValuePairs.length; ++i) {
verifyRecord(
@@ -207,7 +207,7 @@ public class ConsumerRecordFactoryTest {
}
final List<ConsumerRecord<byte[], byte[]>> records =
- factory.create(Arrays.<KeyValue<String, Long>>asList(keyValuePairs));
+ factory.create(Arrays.<KeyValue<String, Integer>>asList(keyValuePairs));
for (int i = 0; i < keyValuePairs.length; ++i) {
verifyRecord(
@@ -236,7 +236,7 @@ public class ConsumerRecordFactoryTest {
}
final List<ConsumerRecord<byte[], byte[]>> records =
- factory.create(Arrays.<KeyValue<String, Long>>asList(keyValuePairs), timestamp, 2L);
+ factory.create(Arrays.<KeyValue<String, Integer>>asList(keyValuePairs), timestamp, 2L);
for (int i = 0; i < keyValuePairs.length; ++i) {
verifyRecord(
