KonstantinCodes / messenger-kafka

Simple Kafka transport for Symfony Messenger.
MIT License
87 stars 35 forks source link

serializer component needs both body and headers in envelop message #6

Closed jbouzekri closed 4 years ago

jbouzekri commented 4 years ago

When used with Symfony serializer component to have json in the topic instead of a php serialized object, you need both the body and headers to decode the message :

https://github.com/symfony/messenger/blob/master/Transport/Serialization/Serializer.php#L64

KonstantinCodes commented 4 years ago

Thanks!