我在使用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。