thanks ingo! i'll look at moving to rolling my own operator and using
ConnectedStreams.transform with it.
On Tue, May 18, 2021 at 3:18 AM Ingo Bürk wrote:
> Hi Jin,
>
> 1) As far as I know the order is only guaranteed for events from the same
> partition. If you want events across partitions to
Hi Jin,
1) As far as I know the order is only guaranteed for events from the same
partition. If you want events across partitions to remain in order you may
need to use parallelism 1. I'll attach some links here which might be
useful:
https://stackoverflow.com/questions/50340107/order-of-events-w
ping?
On Tue, May 11, 2021 at 11:31 PM Jin Yi wrote:
> hello. thanks ahead of time for anyone who answers.
>
> 1. verifying my understanding: for a kafka source that's partitioned on
> the same piece of data that is later used in a keyBy, if we are relying on
> the kafka timestamp as the event
hello. thanks ahead of time for anyone who answers.
1. verifying my understanding: for a kafka source that's partitioned on
the same piece of data that is later used in a keyBy, if we are relying on
the kafka timestamp as the event timestamp, is it guaranteed that the event
stream of the source
