The kafka source is sending bytes

[garciapd]

Since the kafka source is sending just the bytes, the examples is not working, the stream should be something like:

stream create kafka-source-test --definition "kafka --zkconnect=localhost:2181 --topic=kafka-source-test | transform --expression='new java.lang.String(payload)' | log" --deploy

Thanks.