Portable serialization using Avro

[fj.pi...@indizen.com]

Hi, 

After a deep read of hazelcast documentation. I can not find if my scenario is possible in Hazelcast.

I am working with Avro using Kafka, schema registry and kafka streams saving the data in Hazelcast. I want to support portable serialization, because the goal of schema registry is perform the capability of schema evolutions and in my road map is present to add new fields to my schema on a regular basic and all the information saved in Hazelcast must be compatible.

Your documentation talks about PortableSerialization, Implementing Portable class in the POJO, but Avro Pojo is created by a avro schema and you can not implement Portable class.

http://docs.hazelcast.org/docs/latest-development/manual/html/Serialization/Implementing_Portable_Serialization/index.html

is there a way to work with portable serialization using Avro in Hazelcast?. I could save more than one avro schemas in the same iMap, but when I need to red a older object, The serializerConfig have the newest version of the Avro.

As workaround, I tried to modify the serializer each time I go to query Hazelcast, but it is not possible

db.getConfig().setSerializationConfig(serializationConfig);

Exception in thread "main" java.lang.UnsupportedOperationException: Client cannot access cluster config!

Any idea?

Thanks in advance

Regards

[fj.pi...@indizen.com]

Solved.. Hazelcast and avro seem that they are not getting well together. So, we store in IMDG avro object in json format and when we need get Hazelcast data we have implemented a interface in order to serialize the json in a avro generic record object.

Now, I have integrated schema registry schemas evolution with avro and hazelcast.

Regards to Neil from Madrid :)