Hello,
I would like to query a mariadb database for the latest updates based on a timestamp column and then put the retrieved record into kafka.
What would be the best practice to do that? Use a QueryDatabaseTable, convert the result (which is in Avro format) to Json and put that in Kafka? Would that be senseful?
What would you recommend to use as the kafka message key - the incremental id from the database?
Rgds,
Uwe
