[ https://issues.apache.org/jira/browse/BAHIR-165?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16471528#comment-16471528 ]
Prashant Sharma commented on BAHIR-165: --------------------------------------- My guess is mqtt connector currently tries to decode using default character encoding, it should be updated to return message binary without parsing. > The avro messages to streaming-mqtt gives negative value. > ---------------------------------------------------------- > > Key: BAHIR-165 > URL: https://issues.apache.org/jira/browse/BAHIR-165 > Project: Bahir > Issue Type: Bug > Components: Spark Streaming Connectors > Affects Versions: Spark-2.1.1 > Environment: OS : Linux > MQTT publisher : Java application using Eclipse Paho > Reporter: Mohammed Hassan Farish > Priority: Major > Labels: issue, newbie, parsing > Original Estimate: 48h > Remaining Estimate: 48h > > Sending an Avro message with fields id and name to streaming-mqtt. The > messages gets parsed but the value of id is returned as some random negative > number. The result is negative only when the id input is greater than 63. -- This message was sent by Atlassian JIRA (v7.6.3#76005)