# mysql-sync-kafka

**Repository Path**: E_wsq/mysql-sync-kafka

## Basic Information

- **Project Name**: mysql-sync-kafka
- **Description**: 基于 mysql-binlog-connector-java ，实现同步mysql binlog推送到kafka集群，支持数据库、表过滤
- **Primary Language**: Java
- **License**: Not specified
- **Default Branch**: master
- **Homepage**: None
- **GVP Project**: No

## Statistics

- **Stars**: 0
- **Forks**: 5
- **Created**: 2020-10-11
- **Last Updated**: 2020-12-18

## Categories & Tags

**Categories**: Uncategorized

**Tags**: None

## README

# mysql-sync-kafka

#### 介绍
基于 mysql-binlog-connector-java ，实现同步mysql binlog推送到kafka集群，支持数据库、表过滤

#### 软件架构
springboot项目

#### 安装教程

1.  打包 mvn package
2.  启动 java -jar xxx.jar

#### 使用说明

```
#============== mysql-binlog-connector-java 配置 ===================
binlog:
  kafka-topic: receive_mysql_data2
  mysql:
    server-id: 1 # mysql binglog 设置的server-id
    host: ENC(T6WrTn5zVl4CSinjuxQ0ODWWC2XxUklm) #mysql主机地址 已做加密 工具见 JasyptUtil
    port: 3306
    user: ENC(/hObjoJ3yMR2IE89SYHwwQ==)
    passwd: ENC(HjfpULYrlWVWHvVFCpPFTwF7QDiRklRW)
    # 指定要处理的数据表-必须配置，多个用','分割
    table-filter:
      # 全部填 *，指定某个数据库所有表填写 db_name.*
      includes: "test.*"
      # 不做排除 填写空 "" ,excludes 规则优先级高于 includes
      excludes: "test.t_user2"

# 配置示例：配置db_test监听数据库所有的表，但排除t_user
# includes: "db_test.*"
# excludes: "db_test.t_user"
```
-  [mysql-binlog-connector-java](https://github.com/shyiko/mysql-binlog-connector-java)