Hi, from my experience serialization contributes a lot to the maximum achievable throughput. I can strongly recommend checking out this blog post, which has a lot of details on the topic: https://flink.apache.org/news/2020/04/15/flink-serialization-tuning-vol-1.html
On Tue, Nov 10, 2020 at 9:46 AM ashwinkonale <ashwin.kon...@gmail.com> wrote: > Hey, > I am reading messages with schema id and using confluent schema registry to > deserialize to Genericrecord. After this point, pipelineline will have this > objects moving across. Can you give me some examples of `special handling > of > avro messages` you mentioned ? > > > > -- > Sent from: > http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/ >
