flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Tzu-Li (Gordon) Tai" <tzuli...@apache.org>
Subject Re: Kafka and Flink integration
Date Fri, 16 Jun 2017 11:58:46 GMT
Hi!

It’s usually always recommended to register your classes with Kryo, to avoid the somewhat
inefficient classname writing.
Also, depending on the case, to decrease serialization overhead, nothing really beats specific
custom serialization. So, you can also register specific serializers for Kryo to use for the
type.
If you need to store these custom objects as managed state for your operators, you can also
have your own custom Flink TypeSerializer for that.

Best,
Gordon

On 16 June 2017 at 12:27:06 PM, nragon (nuno.goncalves@wedotechnologies.com) wrote:

I have to produce custom objects into kafka and read them with flink. Any  
tuning advices to use kryo? Such as class registration or something like  
that? Any examples?  

Thanks  



--  
View this message in context: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Kafka-and-Flink-integration-tp13792.html
 
Sent from the Apache Flink User Mailing List archive. mailing list archive at Nabble.com.
 

Mime
View raw message