Here is the code. I can only get log in the constructor and configure method.
import org.json.simple.JSONObject;import
org.apache.kafka.common.errors.SerializationException;import
org.apache.kafka.common.serialization.Serializer;
import java.util.Map;import org.slf4j.Logger;import org.slf4j.Logge
unsubscribe
2016-11-14 20:01 GMT+08:00 Andrew Xor :
> Hi,
>
> Since you can't cast one type to another and you are not getting a Null
> exception in order to be better able to help you could you give us the
> implementation of your serializer?
>
> Cheers,
>
> A.
>
> On Mon, Nov 14, 2016 at 9:17
Hi,
Since you can't cast one type to another and you are not getting a Null
exception in order to be better able to help you could you give us the
implementation of your serializer?
Cheers,
A.
On Mon, Nov 14, 2016 at 9:17 AM, Zhechao Ma
wrote:
> Even when I implement my own json serializer,
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 xx
specified in value.serializer
I add
What's your use case of transferring a jar?
If you just want to load jar to worker's classpath, '--jars' option on
upcoming Storm 1.1.0 would help. It provides transferring jars and load
them to workers' classpath.
If you don't want to load jar to worker's classpath, or need dynamic
loading or cla
