I got same error when I send message to Kafka. generally it caused by deserializer as Hemant mentioned. You need to check how the data was send to Kafka, and how is your consumer deserializer defined. And you need to check for both Key and value.
the data is the topic might be byte[] type Sincerely, Selina On Sun, Oct 18, 2015 at 3:01 AM, Kiran Singh <kim.sing...@gmail.com> wrote: > Hi > > I am trying to get message from kafka server using hig level consumer API. > But i am getting following exception > > "java.lang.ClassCastException: [B cannot be cast to java.lang.String" > > Can anyone explain what this means. > > Thanks > Kiran Singh >
