[GitHub] [kafka] joan38 commented on pull request #5566: MINOR: Fix streams Scala peek recursive call

Thu, 23 Aug 2018 17:34:28 -0700 

Could you do the change on this one too please? I forgot to test in between.
```
    testDriver.pipeRecord(sourceTopic, ("1", "value1"))
    acc shouldBe "value1"
    
    testDriver.pipeRecord(sourceTopic, ("2", "value2"))
    acc shouldBe "value1value2"
```

[ Full content available at: https://github.com/apache/kafka/pull/5566 ]
This message was relayed via gitbox.apache.org for [email protected]

Reply via email to