THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
Gliffy Diagram name OutOfOrderResolution-RecordHeaders pagePin 7 version 5
Rejected because it requires an additional materialized table, and does not provide any significant benefit:
Input Tables generated by:
| Code Block |
|---|
stream.flatMapValues().groupByKey().aggregate() |
In this case, multiple KTable updates have the same input record and thus the same offset. Hence, there is no guarantee that offsets are unique and thus we cannot use them to resolve update conflicts.
Solution B - User-Managed GroupBy (Jan's)
...