It seems can't support consume multi topics with different deserialization
schema.
I use protobuf, different topic mapping to different schema.
--
Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/
B) can't be merged.
> What I want is if backpressure happens, consumers can only consume depends
> on my event time.
>
>
>
> --
> View this message in context: http://apache-flink-user-
> mailing-list-archive.2336050.n4.nabble.com/How-can-I-
> handle-backpressure-with-event-time-tp13313
