Hey Telles, This is definitely a serde error. It sounds like your message is not properly formatted as a JSON blob.
If you are trying to just use a string as the message (vs. a well formatted JSON blob), then you should use the StringSerde. Cheers, Chris On 8/7/14 8:05 AM, "Telles Nobrega" <[email protected]> wrote: >Hi, I'm running a simple samza topology that reads from a kafka topic >that >only has two Strings >xx:xx:xx:xxxx;xx >And its throwing an error > >Caught exception in process loop. >org.codehaus.jackson.JsonParseException: Unexpected character ('F' (code >70)): expected a valid value (number, String, array, object, 'true', >'false' or 'null') > at [Source: [B@56dfb465; line: 1, column: 2] >at org.codehaus.jackson.JsonParser._constructError(JsonParser.java:1291) > at >org.codehaus.jackson.impl.JsonParserMinimalBase._reportError(JsonParserMin >imalBase.java:385) >at >org.codehaus.jackson.impl.JsonParserMinimalBase._reportUnexpectedChar(Json >ParserMinimalBase.java:306) > at >org.codehaus.jackson.impl.Utf8StreamParser._handleUnexpectedValue(Utf8Stre >amParser.java:1581) >at >org.codehaus.jackson.impl.Utf8StreamParser._nextTokenNotInObject(Utf8Strea >mParser.java:436) > at >org.codehaus.jackson.impl.Utf8StreamParser.nextToken(Utf8StreamParser.java >:322) >at >org.codehaus.jackson.map.ObjectMapper._initForReading(ObjectMapper.java:24 >32) > at >org.codehaus.jackson.map.ObjectMapper._readMapAndClose(ObjectMapper.java:2 >389) >at org.codehaus.jackson.map.ObjectMapper.readValue(ObjectMapper.java:1667) > at org.apache.samza.serializers.JsonSerde.fromBytes(JsonSerde.scala:33) >at >org.apache.samza.serializers.SerdeManager.fromBytes(SerdeManager.scala:115 >) > at >org.apache.samza.system.SystemConsumers$$anonfun$org$apache$samza$system$S >ystemConsumers$$poll$5.apply(SystemConsumers.scala:245) > at >org.apache.samza.system.SystemConsumers$$anonfun$org$apache$samza$system$S >ystemConsumers$$poll$5.apply(SystemConsumers.scala:242) >at scala.collection.Iterator$class.foreach(Iterator.scala:727) > at scala.collection.AbstractIterator.foreach(Iterator.scala:1157) >at scala.collection.IterableLike$class.foreach(IterableLike.scala:72) > at scala.collection.AbstractIterable.foreach(Iterable.scala:54) >at org.apache.samza.system.SystemConsumers.org >$apache$samza$system$SystemConsumers$$poll(SystemConsumers.scala:242) > at >org.apache.samza.system.SystemConsumers$$anon$1$$anonfun$call$2.apply(Syst >emConsumers.scala:180) >at >org.apache.samza.system.SystemConsumers$$anon$1$$anonfun$call$2.apply(Syst >emConsumers.scala:180) > at >scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scal >a:244) >at >scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scal >a:244) > at scala.collection.Iterator$class.foreach(Iterator.scala:727) >at scala.collection.AbstractIterator.foreach(Iterator.scala:1157) > at scala.collection.MapLike$DefaultKeySet.foreach(MapLike.scala:174) >at scala.collection.TraversableLike$class.map(TraversableLike.scala:244) > at >scala.collection.AbstractSet.scala$collection$SetLike$$super$map(Set.scala >:47) >at scala.collection.SetLike$class.map(SetLike.scala:93) > at scala.collection.AbstractSet.map(Set.scala:47) >at >org.apache.samza.system.SystemConsumers$$anon$1.call(SystemConsumers.scala >:180) > at >org.apache.samza.util.DoublingBackOff.maybeCall(DoublingBackOff.scala:44) >at >org.apache.samza.system.SystemConsumers.choose(SystemConsumers.scala:208) > at org.apache.samza.container.RunLoop.process(RunLoop.scala:73) >at org.apache.samza.container.RunLoop.run(RunLoop.scala:57) > at >org.apache.samza.container.SamzaContainer.run(SamzaContainer.scala:504) >at >org.apache.samza.container.SamzaContainer$.main(SamzaContainer.scala:81) > at org.apache.samza.container.SamzaContainer.main(SamzaContainer.scala) > > > >Has anyone experienced this error before? > >-- >------------------------------------------ >Telles Mota Vidal Nobrega >M.sc. Candidate at UFCG >B.sc. in Computer Science at UFCG >Software Engineer at OpenStack Project - HP/LSD-UFCG
