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.
