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/
Try setting the assigner on the Kafka consumer, rather than on the
DataStream:
https://ci.apache.org/projects/flink/flink-docs-release-1.3/dev/connectors/
kafka.html#kafka-consumers-and-timestamp-extractionwatermark-emission
I believe this will produce a per-partition assigner and forward only the
