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

Reply via email to