Flux groupBy and new traceId for every new portion of data
I want to implement reactive kafka consumer like that:
https://projectreactor.io/docs/kafka/release/reference/[6.8. Concurrent Processing with Partition-Based Ordering
][1]
I want to implement reactive kafka consumer like that:
https://projectreactor.io/docs/kafka/release/reference/[6.8. Concurrent Processing with Partition-Based Ordering
][1]