debezium에서 사용하는 bin 로그 라이브러리는 shyiko이고 NIFI에서도 사용되는 검증된 라이브러리이다.

https://github.com/shyiko/mysql-binlog-connector-java

 

 

실제 Debezium에서 shyiko를 통해 bin 로그를 읽어오는 코드이다. 

https://github.com/debezium/debezium/blob/master/debezium-connector-mysql/src/main/java/io/debezium/connector/mysql/BinlogReader.java

Posted by '김용환'
,