Thanks for the reply Jagadish.
On Tue, Nov 22, 2016 at 10:58 PM, Jagadish Venkatraman
wrote:
> If you are okay with dropping messages when there are ser-de errors, please
> take a look at :
> task.drop.deserialization.errors
Ok.
> Also, you probably want to fix the problem at the source you're
Hi,
I am using json serde to receive json strings from kafka and
automatically convert it to LinkedHashMap. I am using the following
code fragment to achieve this:
LinkedHashMap rawEvent = (LinkedHashMap) envelope.getMessage();
I am now getting an exception when samsa encounters a bad json strin
alization formats like protobuffs/
> avro depending on the use case. Should you want to write your own
> serialization have a look at the SerdeFactory interface.
>
> Thanks
> Jag
>
> On Saturday, November 5, 2016, Raj raj wrote:
>
>> Hi,
>>
>> I am starting out
Hi,
I am starting out with Samza and my test program is able to read a
message from Kafka. My next task is to write the message to KeyValue
store. The message is formatted as Json in Kafka and I am using json
serde as my msg serde. The incoming message is available to me as a
LinkedHashMap when I
