Create MessageContainer to cache deserialized message data on multiple filters · Issue #17 · Netflix/suro · GitHub
More Web Proxy on the site http://driver.im/
You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
Message is the simple container of String routing key and byte[] message payload. For filtering the message, message payload should be deserialized and it can be cached for another filters. Also, some sink needs specific deserialized format, such as Map<String, Object> or Json string like ElasticSearch.
The text was updated successfully, but these errors were encountered:
Message is the simple container of String routing key and byte[] message payload. For filtering the message, message payload should be deserialized and it can be cached for another filters. Also, some sink needs specific deserialized format, such as Map<String, Object> or Json string like ElasticSearch.
The text was updated successfully, but these errors were encountered: