[ https://issues.apache.org/jira/browse/KAFKA-8450?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16856049#comment-16856049 ]
SuryaTeja Duggi commented on KAFKA-8450: ---------------------------------------- [~guozhang] I am thinking of usingĀ KeyValueTimestamp that is already in use. forĀ public final ArrayList<String> processed = new ArrayList<>(); in MockProcessor. > Augment processed in MockProcessor as KeyValueAndTimestamp > ---------------------------------------------------------- > > Key: KAFKA-8450 > URL: https://issues.apache.org/jira/browse/KAFKA-8450 > Project: Kafka > Issue Type: Improvement > Components: streams, unit tests > Reporter: Guozhang Wang > Assignee: SuryaTeja Duggi > Priority: Major > Labels: newbie > > Today the book-keeping list of `processed` records in MockProcessor is in the > form of String, in which we just call the key / value type's toString > function in order to book-keep, this loses the type information as well as > not having timestamp associated with it. > It's better to translate its type to `KeyValueAndTimestamp` and refactor > impacted unit tests. -- This message was sent by Atlassian JIRA (v7.6.3#76005)