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

Question

我开始玩 CDC 和 Kafka connect

经过无数小时的尝试，我开始理解其中的逻辑

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

为了 运行 使用 Kafka Connector 的工作人员，您需要

./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-source-connector-config
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 转换为属性的文档中的配置：https://debezium.io/documentation/reference/1.5/connectors/mysql.html#mysql-example-configuration