This is an automated email from the ASF dual-hosted git repository. mjsax pushed a commit to branch 1.1 in repository https://gitbox.apache.org/repos/asf/kafka.git
commit 005412d9bc2fb72bf5bb0ed45cc6b571a4c3a96a Author: Mats Julian Olsen <m...@plysjbyen.net> AuthorDate: Wed Feb 7 20:53:07 2018 +0100 MINOR: Add attributes `processedKeys` and `processedValues` to MockProcessorSupplier (#3999) Author: Mats Julian Olsen Reviewers: Guozhang Wang <guozh...@confluent.io>, Matthias J. Sax <matth...@confluent.io> --- .../src/test/java/org/apache/kafka/test/MockProcessorSupplier.java | 5 +++++ 1 file changed, 5 insertions(+) diff --git a/streams/src/test/java/org/apache/kafka/test/MockProcessorSupplier.java b/streams/src/test/java/org/apache/kafka/test/MockProcessorSupplier.java index c464aaa..bdc8d40 100644 --- a/streams/src/test/java/org/apache/kafka/test/MockProcessorSupplier.java +++ b/streams/src/test/java/org/apache/kafka/test/MockProcessorSupplier.java @@ -31,6 +31,9 @@ import static org.junit.Assert.assertEquals; public class MockProcessorSupplier<K, V> implements ProcessorSupplier<K, V> { public final ArrayList<String> processed = new ArrayList<>(); + public final ArrayList<K> processedKeys = new ArrayList<>(); + public final ArrayList<V> processedValues = new ArrayList<>(); + public final ArrayList<Long> punctuatedStreamTime = new ArrayList<>(); public final ArrayList<Long> punctuatedSystemTime = new ArrayList<>(); @@ -86,6 +89,8 @@ public class MockProcessorSupplier<K, V> implements ProcessorSupplier<K, V> { @Override public void process(K key, V value) { + processedKeys.add(key); + processedValues.add(value); processed.add((key == null ? "null" : key) + ":" + (value == null ? "null" : value)); -- To stop receiving notification emails like this one, please contact mj...@apache.org.