Hi, There are keyDecoder and valueDecoder that you can specify when creating the KafkaStreamer. Is that what you're looking for?
-Val -- View this message in context: http://apache-ignite-users.70518.x6.nabble.com/Kafka-Streamer-tp8432p8447.html Sent from the Apache Ignite Users mailing list archive at Nabble.com.