[kafka] 02/02: MINOR: Add attributes `processedKeys` and `processedValues` to MockProcessorSupplier (#3999)

[mj...@apache.org]

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 <ma...@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 <gu...@confluent.io>, Matthias J. Sax <ma...@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
mjsax@apache.org.