I am answering my own question -
Looks like we have to explicitly specify the serializerClass for the
producer like this
from("direct:testingKafka").to("kafka:localhost:9092?topic=test&serializerClass=kafka.serializer.StringEncoder")
This worked.
Would be nice if it is handled in Camel if poss
I've tried to give the kafka component a whirl (disclaimer - I am new to both
camel and kafka).
Tried this and got this exception when sending a message to kafka
In my spring class that produces:
@Autowired
private ProducerTemplate template;
public void sendKakfaMessage(Integer id){
