如何在Kafka中设置Debezium SQL Server连接器，而不使用Docker或Windows Server2016上的汇流平台？

Question

我试图在独立模式下使用Kafka捕获SQL Server数据库中的一些更改。在此任务中，汇流平台和Docker不是选项。

源数据库上的CDC已启用。在Kafka方面，我对Debezium Connector有意见。我会描述更多的细节：

---zookeeper.properties：

dataDir=C:/kafka_2.13-2.7.0/data

clientPort=2181

maxClientCnxns=0

admin.enableServer=false

broker.id=0

listeners=PLAINTEXT://localhost:9092

num.network.threads=3

num.io.threads=8

socket.send.buffer.bytes=102400

socket.receive.buffer.bytes=102400

socket.request.max.bytes=104857600

log.dirs=C:/kafka_2.13-2.7.0/kafka-logs

num.partitions=1

num.recovery.threads.per.data.dir=1

offsets.topic.replication.factor=1

transaction.state.log.replication.factor=1

transaction.state.log.min.isr=1

log.retention.hours=168

log.segment.bytes=1073741824

log.retention.check.interval.ms=30000

zookeeper.connect=localhost:2181

zookeeper.connection.timeout.ms=18000

group.initial.rebalance.delay.ms=0

auto.create.topics.enable=true

delete.topic.enable=true

----SQLServer-Source-Connector。属性：

name=sqlserver-connector

connector.class=io.debezium.connector.sqlserver.SqlServerConnector 

database.hostname=myhostname 

database.port=1433 

database.user=sa 

database.password=mySuperSecretPassord

database.dbname=myDbName 

database.server.name=myhostname

table.include.list=dbo.employes 

database.history.kafka.bootstrap.servers=myhostname:9092 

database.history.kafka.topic=dbhistory.fullfillment

key.converter=org.apache.kafka.connect.json.JsonConverter

value.converter=org.apache.kafka.connect.json.JsonConverter

offset.storage.file.filename=C:/kafka_2.13-2.7.0/connect.offsets

bootstrap.servers=localhost:9092

----file-employes-sink.properties：

name=file-employes-sink

connector.class=FileStreamSink

tasks.max=1

file=file-employes-sink.txt

topics=myhostname.dbo.EMPLOYES

当我想跑的时候

.\connect-standalone.bat ..\..\config\sqlserver-source-connector.properties ..\..\config\file-employes-sink.properties

并检查可以通过链接http：//localhost:8083/connectors创建的连接器,以下是我得到的信息：

[“文件-雇员-接收器”]

这意味着我只能创建我的接收器连接器，对吗？我的源连接器呢？不是应该列在这里吗？

Answer 1

您需要提供connect-standalone.properties作为connect-standalone的第一个参数来配置工作人员

然后提供两个连接器属性文件以启动两个连接器

您还可以使用connect-distributed及其属性文件，然后HTTP发布两个连接器配置