提供独立Kafka Connect的连接器属性文件示例

Question

我开始玩CDC和Kafka connect

经过无数个小时的尝试，我终于明白了的逻辑

1. 使用集群信息设置Kafka Connect属性(bin/Connect standalone.sh(
2. 设置Kafka Connect配置文件(config/Connect-standalone.properties(
3. 下载您的Kafka连接器(在本例中为Debizium的MySQL(
4. 在whatevername.properties中配置连接器属性

为了使用Kafka连接器运行工作程序，您需要

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

哪个回答：

INFO Usage: ConnectStandalone worker.properties connector1.properties [connector2.properties ...] (org.apache.kafka.connect.cli.ConnectStandalone:62)

我知道我们需要运行：

./bin/connect-standalone.sh config/connect-standalone.properties myconfig.properties

我的问题是，我找不到任何格式描述，也找不到myconfig.properties字段的示例。

【额外信息】Debizium配置属性列表：

1. https://docs.confluent.io/debezium-connect-mysql-source/current/mysql_source_connector_config.html#mysql-源连接器配置
2. https://debezium.io/documentation/reference/1.5/connectors/mysql.html

【问题】在哪里可以找到连接器属性的示例

谢谢！

Answer 1

我不确定我是否理解你的问题，但下面是这个连接器的属性示例：

connector.class=io.debezium.connector.mysql.MySqlConnector
connector.name=someuniquename
database.hostname=192.168.99.100
database.port=3306
database.user=debezium-user 
database.password=debezium-user-pw
database.server.id=184054
database.server.name=fullfillment
database.include.list=inventory
database.history.kafka.bootstrap.servers=kafka:9092 
database.history.kafka.topic=dbhistory.fullfillment
include.schema.changes=true

原始配置是我从json转换为properties的文档中的配置：https://debezium.io/documentation/reference/1.5/connectors/mysql.html#mysql-示例配置