Hi Saurabh,
This may be not an answer to your question, but from the bean id I guess you 
try to implement a Kafka streamer.Please check if [1] will work for you.
[1] 
https://ignite.apache.org/releases/1.5.0.final/javadoc/org/apache/ignite/stream/kafka/KafkaStreamer.html
-Roman

Reply via email to