Re: ERROR Processor got uncaught exception. (kafka.network.Processor) with java.lang.ArrayIndexOutOfBoundsException

2016-07-15 Thread
Sorry, please ignore my stupidity, I found it's due to empty topic name, the topic name was reset to empty string at some point in the application code. 2016-07-15 15:46 GMT+08:00 王天鹏 : > Hello, today I my kafka producer stop working, here is the story: > Spark: v1.6.2 > Kafka br

ERROR Processor got uncaught exception. (kafka.network.Processor) with java.lang.ArrayIndexOutOfBoundsException

2016-07-15 Thread
Hello, today I my kafka producer stop working, here is the story: Spark: v1.6.2 Kafka broker: v0.9.0.1 Kafka client: tried 0.9.x and 0.10.x In a spark batch job, I created a kafka producer and tried to send some messages to kafka broker, it works without any problem for > one month until today :(