Name		Name	Last commit message	Last commit date
Latest commit History 2 Commits
.settings		.settings
bin		bin
config		config
resources		resources
src		src
target/classes		target/classes
.DS_Store		.DS_Store
.classpath		.classpath
.project		.project
README.md		README.md
pom.xml		pom.xml

Repository files navigation

解析MySQL BinLog实体

主要功能

连接MySQL数据库
通过引用Jar解析Binlog
封装Binlog为JSON格式
JSON数据发送到Kafka中

目前版本存在问题

每次都需要更新配置文件，性能较差
封装存在问题，目前使用GenericMessage作为消息传递，后期版本使用String作为封装
配置性方面，需要更好的通用化配置

BUG

目前引用程序中，使用原生java.sql.XXX中的对象生成的相应程序。比如timestamp/date等，使用的是UTC +/-0时区，造成时间存在偏差

About

No description, website, or topics provided.

Report repository

Releases

No releases published

Packages

No packages published

Languages

Java 100.0%