Can you keep everything in one thread, not creating new threads for each question you have? Makes easy to follow the whole conversation.
You almost there, you just need to extract the values from the SinkRecord and add them to your Bus object. See the Kafka API how to do extract values from SinkRecord. Related threads: http://apache-ignite-users.70518.x6.nabble.com/How-to-solve-SinkRecord-cannot-be-cast-exception-unsolved-td13221.html http://apache-ignite-users.70518.x6.nabble.com/Kindly-tell-me-where-to-find-these-jar-files-td12649.html http://apache-ignite-users.70518.x6.nabble.com/Where-should-I-place-Kafka-connect-converter-class-files-td13214.html Actually an answer was given here already http://apache-ignite-users.70518.x6.nabble.com/How-to-configure-Ignite-sink-connector-to-use-key-value-td13162.html Other related threads: http://apache-ignite-users.70518.x6.nabble.com/How-to-implement-StreamSingleTupleExtractor-in-Kafka-connect-Ignite-sink-td13166.html -- View this message in context: http://apache-ignite-users.70518.x6.nabble.com/How-to-create-custom-SinkRecord-extractor-tp13261p13264.html Sent from the Apache Ignite Users mailing list archive at Nabble.com.
