samza-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Shekar Tippur <ctip...@gmail.com>
Subject Deserializing issue
Date Fri, 20 Feb 2015 00:00:31 GMT
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

Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message