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/
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.html
> Sent from the Apa
50.n4.nabble.com/How-can-I-handle-backpressure-with-event-time-tp13313.html
Sent from the Apache Flink User Mailing List archive. mailing list archive at
Nabble.com.