求Kafka与MariaDB集成的示例项目链接（Ubuntu 22.04环境）

你的环境配置 #

操作系统 #

NAME="Ubuntu"
VERSION_ID="22.04"
VERSION="22.04.1 LTS (Jammy Jellyfish)"
VERSION_CODENAME=jammy
ID=ubuntu
ID_LIKE=debian

Kafka 版本 #

3.3.1 (Commit:e23c59d00e687ff5)

MariaDB 版本 #

mysql  Ver 15.1 Distrib 10.6.7-MariaDB, for debian-linux-gnu (x86_64) using  EditLine wrapper

集成示例资源获取方式 #

你可以通过以下关键词在对应平台搜索相关资源：

• GitHub 示例项目：搜索 kafka-mariadb-integration、kafka-connect-jdbc-mariadb-example，能找到大量基于 Kafka Connect JDBC 连接器的完整项目，涵盖双向数据同步场景。
• 视频教程：在视频平台搜索 Kafka MariaDB 集成实战、Kafka Connect JDBC 配置 MariaDB，可找到分步实操演示内容。

核心集成实操示例（Kafka Connect JDBC） #

这是最常用的集成方案，以下是基础配置步骤：

1. 准备连接器 #

下载适配 Kafka 3.3.1 的 Kafka Connect JDBC 连接器包，解压到 Kafka 的 plugins 目录。

2. MariaDB 到 Kafka 同步（Source 连接器） #

创建配置文件 mariadb-source.properties：

name=mariadb-source-connector
connector.class=io.confluent.connect.jdbc.JdbcSourceConnector
tasks.max=1
connection.url=jdbc:mariadb://localhost:3306/your_db?user=your_user&password=your_pwd
table.whitelist=your_table
mode=incrementing
incrementing.column.name=id
topic.prefix=kafka_topic_

启动连接器：

bin/connect-standalone.sh config/connect-standalone.properties mariadb-source.properties

3. Kafka 到 MariaDB 同步（Sink 连接器） #

创建配置文件 mariadb-sink.properties：

name=mariadb-sink-connector
connector.class=io.confluent.connect.jdbc.JdbcSinkConnector
tasks.max=1
topics=kafka_topic_your_table
connection.url=jdbc:mariadb://localhost:3306/your_db?user=your_user&password=your_pwd
auto.create=true
auto.evolve=true
insert.mode=upsert
pk.fields=id

启动连接器：

bin/connect-standalone.sh config/connect-standalone.properties mariadb-sink.properties

内容的提问来源于stack exchange，提问作者logesh sankar