debeziumsql-server连接获取auto.offset=latest错误



我在使用Debezium时遇到问题。我在网上搜索了一下,但找不到解决办法。我使用的是Windows 11和Kafka 3.1

以下是我的配置值:

动物园管理员。属性:

dataDir=C:/debezium/kafka/data/zookeper

clientPort=2181

maxClientCnxns=0

admin.enableServer=错误

服务器属性

broker.id=0

listeners=PLAINTEXT://localhost:9092

num.network.threads=3

num.io.threads=8

socket.send.buffer.bytes=102400

socket.rereceive.buffer.bytes=102400

socket.request.max.bytes=104857600

num.partitions=1

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

对数保留时间=168

log.segment.bytes=1073741824

log.reduration.check.interval.ms=300000

zookeeper.connect=localhost:2181

zookeeper.connection.timeout.ms=18000

group.initial.rebalance.delation.ms=0

独立连接。属性

bootstrap.servers=localhost:9092

key.coverter=org.apache.kafka.connect.json.json转换器

value.coverter=org.apache.kafka.connect.json.json转换器

key.coverter.schemas.enable=真

value.coverter.schemas.enable=真

offsets.storage.filename=C:/debezium/kafka/connect/connect.offsets

offset.flash.interval.ms=10000

offset.reset=最新

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

和transaction_connector.properties

name=钱包交易连接器

连接器.class=io.debezium.connecter.sqlserver.sqlserver连接器

database.hostname={MY_hostname}

database.port=1433

database.user=sa

database.password={SQL_password}

database.server.name={REMOTE_SQL_server}

database.dbname=钱包数据库

table.include.list=dbo.TxOpenProvision

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

database.history.kafka.ttopic=数据库历史.TxOpenProvision

include.schema.changes=真实

我在下面运行zookeeper、kafka和connect命令:

  • 动物园:。\bin\windows\zookeeper-server-start.bat.\config\zookeeper.properties
  • 卡夫卡:。\bin\windows\kafk-server-start.bat.\config\server.properties
  • 连接:。\bin\windows\connect-standalone.bat.\config\connect-standalon.properties.\config\wallet_connector.properties

我的SQL Server是远程服务器。

我遇到这个错误,无法解决。我该如何解决?

错误〔钱包交易连接器|任务-0〕WorkerSourceTask{id=wallet-transaction-connector-0}Task引发了未捕获且不可恢复的异常。任务正在被杀死并且将手动重新启动后才能恢复(org.apache.kafka.connect.runtime.WorkerTask:195)org.apache.kafka.commun.config.ConfigException:无效值earl²est对于配置auto.offset.reset:字符串必须是以下之一:最新,最早,没有网址:org.apache.kafka.common.config.ConfigDef$ValidString.ensureValid(ConfigDef.java:961)网址:org.apache.kafka.common.config.ConfigDef.parseValue(ConfigDef.java:499)网址:org.apache.kafka.common.config.ConfigDef.parse(ConfigDef.java:483)网址:org.apache.kafka.common.config.AbstractConfig.(AbstractConfig.java:113)网址:org.apache.kafka.common.config.AbstractConfig.(AbstractConfig.java:133)网址:org.apache.kafka.clients.consumer.ConsumerConfig.(ConsumerConfig.java:630)网址:org.apache.kafka.clients.consumer.KafkaConsumer.(KafkaConsumer.java:664)网址:org.apache.kafka.clients.consumer.KafkaConsumer.(KafkaConsumer.java:645)网址:org.apache.kafka.clients.consumer.KafkaConsumer.(KafkaConsumer.java:625)位于io.debezium.rerelational.history.FafkaDatabaseHistory.storageExists(KafkaDatabaseHistory.java:356)位于io.debezium.rerelation.HistorizedRelationalDatabaseSchema.initializeStorage(HistorizedRelationalDatabaseSchema.java:80)位于io.debezium.connecter.sqlserver.SqlServerConnectorTask.start(SqlServerConnectorTask.java:81)位于io.debezium.connecter.common.BaseSourceTask.start(BaseSourceTask.java:130)位于org.apache.kafka.connect.runtime.WorkerSourceTask.initializeAndStart(WorkerSourceTask.java:225)网址:org.apache.kafka.connect.runtime.WorkerTask.doRun(WorkerTask.java:186)网址:org.apache.kafka.connect.runtime.WorkerTask.run(WorkerTask.java:243)位于java.util.concurrent.Executors$RunnableAdapter.call(Executitors.java:511)位于java.util.concurrent.FFutureTask.run(FutureTask.java:266)位于java.util.concurrent.ThreadPoolExecutiator.runWorker(ThreadPoolExecutiator.java:1149)位于java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)在java.lang.Thread.run(Thread.java:750)

正如您在日志中看到的,您有一个特殊字符²-Invalid value earl²est

connect-standalone.properties中,配置offset.reset不是有效的配置。。。

Debezium是一个生产者(源连接器),所以设置auto.offset.reset对它来说没有意义

同样值得指出的是,Windows对卡夫卡的支持非常缺乏;请尝试使用WSL2。

相关内容

最新更新