Even when I implement my own json serializer, it still throws the similar exception, but no more details for debug.:
org.apache.kafka.common.errors.SerializationException: Can't convert value of class org.apache.storm.shade.org.json.simple.JSONObject to xxxxxx specified in value.serializer I add a LOG in the overriding method byte[] serialize(String topic, JSONObject data), and found no logs in worker.log. That is to say this exception is throwed before method serialize is called. 2016-11-07 16:50 GMT+08:00 Zhechao Ma <[email protected]>: > I'm using KafkaBolt to write data to kafka. Tuple to kafka map is <String, > JSONObject>. > I set both *key.serializer* and *value.serializer* as > "org.apache.kafka.common.serialization.StringSerializer". I get the > following Exception: > > org.apache.kafka.common.errors.SerializationException: Can't convert > value of class org.apache.storm.shade.org.json.simple.JSONObject to class > org.apache.kafka.common.serialization.StringSerializer specified in > value.serializer > > > I cannot find other serializers related to JSON, and I'm using storm 1.0.2 > and kafka 0.8.1.1. > > Could anyone help ? > > -- > Thanks > Zhechao Ma > -- Thanks Zhechao Ma
