Procedure to populate streaming data into Kafka partition based on business logic.

Hi,

I am doing a project where I am migrating data to kafka topic from Oracle DB. As per our requirement we need to populate data into a particular partition based on some column value in source table. For example:- My table X has a column name "COL" which is having 4 unique value i.e.A,B,C,D. My requirement is I want to populate data into a particular kafka topic partition based on the value of COL column in X table. If the row is having COL value A it will be inserted into partition no 0, if it is B then