Kafka.MessageParser and deserialization

[nicogiard]

Hi David, me again...

Do you thing the Kafka.MessageParser can rely on the QueueReferences instead of the "HeaderNames.MessageType" to deserialize the message ?

(again some issues with interoperability)

Thank you

[mizrael]

hi Nicolas, can you please clarify a little bit?

[nicogiard]

Thanks for your answer.

I'm in a situation where all my microservices are not developed with .net. And even if they are with .net, opensleigh is not mandatory.
So i can't rely on the Header "MessageType" in the message.

I tried some experiences, in the Kafka.MessageParser, to change this behavior, and one of my intuitions, was that the association between Topic and "POCO" is already known by the QueueReferences.

Do you think that, according to your architecture, there is a way to retrieve le Type of the POCO to deserialize, based on the topic name and the QueueReferences ?

[mizrael]

so you have messages on a Kafka queue that are generated outside OpenSleigh and received by an OpenSleigh app anyway?

[nicogiard]

You're right, My saga is handled by OpenSleigh, but my Microservices are built with java/.net (without OpenSleigh). And i can't force them to add a metadata with the C# class to deserialize with.

[nicogiard]

I have made a little PR to express my ideas. Here it is : #39

[mizrael]

thanks! I've made some minor changes and added more tests :)