Hello,
As I am trying to extend what we have to other sources, I changed some
code. Looks like deserialization is broken.
Here is a sample stream input:
{"creation_time":"2015-02-19T04:03:51Z","alert_policy_name":"Alert
Policy","application_name":"PROD AWS","business_unit_l1":"CEG"}
envelope.getMessage().toString()
Transforms it to:
{creation_time=2015-02-04T20:41:36Z, alert_policy_name=Alert
Policy,application_name=Prod AWS,business_unit_l1=CEG}
As we can see, the json structure seem to be broken.
I have this in the config file:
systems.kafka.streams.Alert.samza.msg.serde=json
systems.kafka.samza.msg.serde=json
Wondering what could be wrong.
- Shekar
