Json load error with string values in topics about faust

[vineetgoel]

This might be related to the json fix we made earlier. I tried producing strings to this using the kafka-console-producer. Not sure what is going wrong. Could this be because of the value being a bytestring?

[vineetgoel]

Looks like currently we require that we serialize/deserialize the values and the only supported codec at this point is json. Due to this, when producing messaegs as:

foo
bar

results in the above error.

However if we make these into json serialized strings as follows:

"foo"
"bar"

we get the expected behavior

[ask]

Isn't this fixed by the new:

    greetings_topic = app.topic('greetings', value_type=str, value_serializer='raw')

?

I'm still wondering if value_type=str should imply raw serializer and not json, as it seems
kind of silly to json serialize a string. But maybe that is more DWIM than explicit.

[vineetgoel]

Yeah I think this should be fixed with the new raw serializer. Maybe we could decode the bytes into str for DWIM purposes? But, should be fine as is