I agree, actually before @bbejeck 's PR the line was 

```
joinOther.repartitionForJoin(Joined.with(joined.keySerde(), 
joined.otherValueSerde(), joined.valueSerde()));
```

to intentionally switch other value serde and value serde, but the pervious PR 
dropped this.

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

Reply via email to