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