debezium sql server connect获取auto.offset.reset=latest错误

Question

我在使用德贝兹姆时遇到问题。我在互联网上搜索，但我找不到解决方案。我使用的是视窗 11 和Kafka 3.1

以下是我的配置值：

动物园管理员属性：

data Dir=C：/de be zi um/kafka/data/zoo ke per

客户端端口=2181

最大客户端神经网络 =0

admin.enableServer=false

server.properties

broker.id=0

侦听器 = 纯文本：//本地主机：9092

网络线程数=3

线程数 = 8

socket.send.buffer.bytes=102400

socket.receive.buffer.bytes=102400

socket.request.max.bytes=104857600

分区数量=1

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

log.retention.hours=168

log.segment.bytes=1073741824

log.retention.check.interval.ms=300000

动物园管理员连接=本地主机：2181

zookeeper.connection.timeout.ms=18000

group . initial . rebalance . delay . ms = 0

连接-标准.属性

bootstrap.servers=localhost:9092

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

value . converter = org . Apache . Kafka . connect . JSON . JSON converter

key.conformer.schemas.enable=真

value.converter.schemas.enable=真

offset.storage.file.filename=C：/debezia/kafka/connect/connect.offsets

offset.flush.interval.ms=10000

offset.reset =最新

plugin.path=C:/debezium/kafka/connect

和transaction_connector属性

name =钱包-交易-连接器

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

数据库主机名= {MY_HOSTNAME}

database.port=1433

database.user=sa

数据库.密码= { SQL _密码}

database.server.name= {REMOTE_SQL_SERVER}

database.dbname=WalletDB

table.include.list=dbo。TxOpenProvision

database.history.kafka.bootstrap.servers=localhost：9092

database.history.kafka.topic=dbhistory.TxOpenProvision

包括.架构更改 = true

我运行动物园管理员kafka并连接下面的命令：

• 动物园管理员：.\bin\windows\zookeeper服务器启动。蝙蝠.\config\zookeeper。属性
• Kafka:.\bin\windows\Kafka服务器启动。bat.\config\server。属性
• 连接：.\bin\windows\Connect standalone。bat.\config\connect单机版。属性.\config\wallet_connector.properties

我的SQL服务器是远程服务器。

我收到了这个错误，但我无法解决它。我该如何解决这个问题？

错误 [钱包-交易-连接器|任务-0] WorkerSourceTask{id=钱包-交易-连接器-0} 任务抛出了一个未捕获且不可恢复的异常。任务正在被终止，直到手动重新启动（组织.apache.kafache.connect.runtime.WorkerTask：195） 组织.apache.kafka.common.config.config.config：configException：无效值 earl²est 用于配置自动.offset.reset：字符串必须是以下之一：最新，最早，无在组织.apache.kafka.common.config.configString.ensureValid（ConfigDef.java：961） 在组织.apache.kafka.common.configDef.parseValue（ConfigDef.java：499）在 org.apache.kafka.common.config.configDef.parse（ConfigDef.java：483） 在 org.apache.kafka.common.config.AbstractConfig.（摘要配置.java：113）（摘要配置.java：133）在组织（消费者配置.java：630） 在组织.apache.kafka.clients.consumer.kafkaConsumer.（Kafka消费者.java：664） 在 org.apache.kafka.clients.消费者.kafka消费者。（Kafka消费者.java：645） 在组织.apache.Kafka.clients.消费者.Kafka消费者。（KafkaConsumer.java：625） at io.debezium.relational.history.KafkaDatabaseHistory.storageExists（KafkaDatabaseHistory.java：356） at io.debezium.relational.hisationalDatabaseSchema.initializeStorage（HistorizedRelationalDatabaseSchema.java：80） at io.debezium.connector.sqlserver.SqlServerConnectorTask.start（SqlServerConnectorTask.java：81） at io.debezium.connector.common.BaseSourceTask.start（BaseSourceTask.java：130） atorg.apache.kafka.connect.runtime.WorkerSourceTask.initializeAndStart（WorkerSourceTask.java：225） at org.apache.kafka.connect.runtime.WorkerTask.doRun（WorkerTask.java：186） at org.apache.kafka.connect.runtime.WorkerTask.run（WorkerTask.java：243） at java.util.concurrent.executors$RunnableAdapter.call（执行器.java：511） at java.util.concurrent.concurrent.FutureTask.run（未来任务.java：266） at java.util.concurrent.ThreadPoolExecutor.runWorker（ThreadPoolExecutor.java：1149）at java.util.concurrent.ThreadPoolExecutor$Worker.run（线程池加速器.java：624） at java.lang.Thread.run（线程.java：750）

Answer 1

正如您在日志中看到的，您有一个特殊字符² - 无效值 earl²est

在连接独立属性中，配置偏移量重置不是有效的配置...

Debezium是一个生产者(源连接器)，所以设置< code>auto.offset.reset对它没有意义。

还值得指出的是，Windows对Kafka的支持非常缺乏;请尝试改用 WSL2。