shyiko/mysql-binlog-connector-java

Partitioned Mysql tables

sukeshac opened this issue · 0 comments

I am using debezium mysql connector to read bin log content.

When a table has been partitioned, the binary log records the partition
information as below.

image

I need to get this partition details so that i can push the messages to different Kafka topic partitions.
But i could not find this partition details in the EventData from the bin log reader .

Please let me know how to get table partition details if the details are already captured, if not please support to parse the table partition details as it already recorded in mysql bin logs.
The same is supported for insert/update/delete operations in bin logs.