THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
| Code Block | ||
|---|---|---|
| ||
builder.stream("topic")
.repartition((key, value) -> value.newKey(), Repartitioned.withNumberOfPartitions(5))
.groupByKey()
.count(); |
Follow-up ticket for this feature can be found here:
| Jira | ||||||||
|---|---|---|---|---|---|---|---|---|
|
Rejected KSream interface changes:
...