Check SinkRecord#value() [1]. Cast the object to the data type you use in your Kafka connector and extract the field you need.
And please continue posting your questions related to this topic in one thread -- we have a bunch already. Thank you! [1] https://kafka.apache.org/0100/javadoc/index.html?org/apache/kafka/connect/sink/SinkRecord.html -- Roman On Wednesday, May 31, 2017 5:29 PM, ignitedFox <[email protected]> wrote: hi, I have records in kafka like; Each record represents a "Bus" entry, with bus ID, route, etc. The records are fetched from DB using Kafka JDBC Connector. I want to insert them to Ignite, having "BUS_ID" as the key, and Bus object as the value. I got to know that there need to do something like But I dont know how to do this. Somebody kindly help me on this? Thank you -- View this message in context: http://apache-ignite-users.70518.x6.nabble.com/How-to-create-custom-SinkRecord-extractor-tp13261.html Sent from the Apache Ignite Users mailing list archive at Nabble.com.
