THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
- Add the following method to KStream:
| Code Block | ||
|---|---|---|
| ||
KStream<K, V> distinct(DistinctParametersDistinctParameters<K, V> params) |
2. Add and implement the following DistinctParameters class:
...