- html - 出于某种原因,IE8 对我的 Sass 文件中继承的 html5 CSS 不友好?
- JMeter 在响应断言中使用 span 标签的问题
- html - 在 :hover and :active? 上具有不同效果的 CSS 动画
- html - 相对于居中的 html 内容固定的 CSS 重复背景?
尝试使用以下配置为 SqlServer Connector 设置 debezium 嵌入式引擎
config = Configuration.create()
.with("connector.class", "io.debezium.connector.sqlserver.SqlServerConnector")
.with("offset.storage", "org.apache.kafka.connect.storage.FileOffsetBackingStore")
.with("offset.storage.file.filename", "/path/to/storage/offset.dat")
.with("offset.flush.interval.ms", "60000")
.with("name", "localSqlServerconnector")
.with("database.hostname", "localhost")
.with("database.port", "1433")
.with("database.user", "sa")
.with("database.password", "pwd@123")
.with("database.server.id", "12345")
.with("database.server.name", "localSqlServer")
.with("database.history", "io.debezium.relational.history.FileDatabaseHistory")
.with("database.history.file.filename", "/path/to/storage/dbhistory.dat")
.with("database.history.kafka.topic", "localMysqlServer.dbo")
.with("database.dbname", "sampledb")
.with("table.whitelist", "dbo.student")
.build();
engine = EmbeddedEngine.create().using(config).notifying(this::handleEvent).build();
ExecutorService executor = Executors.newSingleThreadExecutor();
executor.execute(engine);
下面是用于为 SqlServer 连接器建立 debezium 嵌入式引擎设置的依赖项。
<dependency>
<groupId>io.debezium</groupId>
<artifactId>debezium-embedded</artifactId>
<version>0.8.3.Final</version>
</dependency>
<dependency>
<groupId>io.debezium</groupId>
<artifactId>debezium-connector-sqlserver</artifactId>
<version>0.9.0.Final</version>
</dependency>
下面是我尝试启动 debezium 嵌入式引擎时发生的错误
java.lang.NoClassDefFoundError: io.debezium.relational.HistorizedRelationalDatabaseConnectorConfig
at java.lang.ClassLoader.defineClassImpl(Native Method) ~[na:1.8.0_202]
at java.lang.ClassLoader.defineClass(ClassLoader.java:379) ~[na:1.8.0_202]
at java.security.SecureClassLoader.defineClass(SecureClassLoader.java:142) ~[na:1.8.0_202]
at java.net.URLClassLoader.defineClass(URLClassLoader.java:682) ~[na:1.8.0_202]
at java.net.URLClassLoader.access$400(URLClassLoader.java:89) ~[na:1.8.0_202]
at java.net.URLClassLoader$ClassFinder.run(URLClassLoader.java:1086) ~[na:1.8.0_202]
at java.security.AccessController.doPrivileged(AccessController.java:739) ~[na:1.8.0_202]
at java.net.URLClassLoader.findClass(URLClassLoader.java:589) ~[na:1.8.0_202]
at java.lang.ClassLoader.loadClassHelper(ClassLoader.java:934) ~[na:1.8.0_202]
at java.lang.ClassLoader.loadClass(ClassLoader.java:879) ~[na:1.8.0_202]
at sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:349) ~[na:1.8.0_202]
at java.lang.ClassLoader.loadClass(ClassLoader.java:862) ~[na:1.8.0_202]
at io.debezium.connector.sqlserver.SqlServerConnectorTask.getAllConfigurationFields(SqlServerConnectorTask.java:220) ~[debezium-connector-sqlserver-0.9.0.Final.jar:0.9.0.Final]
at io.debezium.connector.common.BaseSourceTask.start(BaseSourceTask.java:36) ~[debezium-core-0.8.3.Final.jar:0.8.3.Final]
at io.debezium.embedded.EmbeddedEngine.run(EmbeddedEngine.java:677) ~[debezium-embedded-0.8.3.Final.jar:0.8.3.Final]
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) [na:1.8.0_202]
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) [na:1.8.0_202]
at java.lang.Thread.run(Thread.java:813) [na:1.8.0_202]
Caused by: java.lang.ClassNotFoundException: io.debezium.relational.HistorizedRelationalDatabaseConnectorConfig
at java.net.URLClassLoader.findClass(URLClassLoader.java:591) ~[na:1.8.0_202]
at java.lang.ClassLoader.loadClassHelper(ClassLoader.java:934) ~[na:1.8.0_202]
at java.lang.ClassLoader.loadClass(ClassLoader.java:879) ~[na:1.8.0_202]
at sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:349) ~[na:1.8.0_202]
at java.lang.ClassLoader.loadClass(ClassLoader.java:862) ~[na:1.8.0_202]
... 18 common frames omitted
如果遗漏了什么,请告诉我。谢谢。
最佳答案
为了避免 API 之间的冲突,请保持同一组 ID 中的版本相同。您错过了 debezium-core
dependentecy
<!-- https://mvnrepository.com/artifact/io.debezium/debezium-core -->
<dependency>
<groupId>io.debezium</groupId>
<artifactId>debezium-core</artifactId>
<version>1.1.2.Final</version>
</dependency>
<dependency>
<groupId>io.debezium</groupId>
<artifactId>debezium-embedded</artifactId>
<version>1.1.2.Final</version>
</dependency>
<dependency>
<groupId>io.debezium</groupId>
<artifactId>debezium-connector-sqlserver</artifactId>
<version>1.1.2.Final</version>
</dependency>
同时将具有相同组 ID 的所有工件的版本更改为 1.1.2.Final
还将相同的 jar 添加到运行时环境的类路径
关于java - 无法为 SqlServer 连接器设置 debezium 嵌入式引擎,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/62287149/
在我的 Windows 类库(由 MVC 网站使用)中,我安装了 NugetPackage Microsoft.SqlServer.Types (Spatial)。 现在,我正在使用 ado.net
测试sql: 复制代码代码如下: SET STATISTICS IO ON SET STATISTICS TIME ON SELECT COUNT(1)&n
我正在从 SqlConnection 构建 DbContext。当我使用它时,我收到以下错误: The Entity Framework provider type 'System.Data.Enti
我使用dotNet 4.5创建了WCF服务。数据库层是使用Entity Framework 6构建的。 我使用IIS 8托管了该服务。它运行正常。 现在,我需要使用Windows窗体客户端使用该服务,
我正在尝试从 SqlServer 1 上的 sql 数据库中导出一些表。在我们的内部网 LAN(就在我旁边)中有一个我制作的临时 Sql Server,称为 SqlServer 2。 我不想备份整个数
Error 1 Copying file bin\EntityFramework.SqlServer.xml to obj\Debug\Package\PackageTmp\bin\Entit
我正在尝试使用 SMO 通过 Powershell 恢复数据库,但是当我尝试定义和使用服务器对象时,出现以下错误: Cannot convert argument "srv", with value:
出于某种原因,我需要将我的表列之一从“NOT NULL”更新为“NULL”。命令很简单: ALTER TABLE TBLOGDOCMESSAGE ALTER COLUMN PROCESSID BIGI
我想知道我正在尝试做的事情是否可行。我相信它是在 TSQL 中使用 PIVOT 函数,但对 PIVOT 函数没有足够的经验来知道从哪里开始。 基本上,我正在尝试采用以下名为 #tmpbudgetdat
我正在尝试将子查询作为带有条件的列。 我从 SQL Server 得到的错误是: 子查询返回了 1 个以上的值。当子查询跟随 =、!=、、>= 或当子查询用作表达式时,这是不允许的。 我正在选择更多的
我有一个正在查询的 SQL 服务器数据库,我只想在特定行为空时获取信息。我使用了一个 where 语句,例如: WHERE database.foobar = NULL 它不返回任何东西。但是,我知道
1、拼接字符串(整个字符串不分割)步骤: 首先在字符串的前后加单引号; 字符串中的变量以'''+@para+'''在字符串中表示; 若在执行时存在类型转换错误,则应用相应的类型
说明: 收缩日志的原因有很多种,有些是考虑空间不足,有些则是应用程序限制导致的。 ?
Rand()函数是系统自带的获取随机数的函数,可以直接运行select rand() 获取0~1之间的float型的数字。 如果想要获取0~100之间的整数随机数,可以这样使用 select ro
将以下内容保存为 openSql.bat 双击运行即可 复制代码 代码如下: @echo ========= SQL Server Ports =================== @ech
新增的APPLY表运算符把右表表达式应用到左表表达式中的每一行。它不像JOIN那样先计算那个表表达式都可以,APPLY必选先逻辑地计算左表达式。这种计算输入的逻辑顺序允许吧右表达式关联到左表表达式。
SQL Server本身提供了这么一个DMV来返回这些信息,它就是sys.dm_exec_sessions 。 比如在我的机器上做一下查询: 复制代码 代码如下: SELECT * FROM
尽管从技术上讲,其它排名函数的计算与ROW_NUMBER类似,但它们的的实际应用却少很多。RANK和DENSE——RANK主要用于排名和积分。NTILE更多地用于分析。 先创建一个示例表: 复制
1、文件和文件组的含义与关系 每个数据库有一个主数据文件.和若干个从文件。文件是数据库的物理体现。 文件组可以包括分布在多个逻辑分区的文件,实现负载平衡。文件组允许对文件进行分组,以便于管理和数据的
我想很多人都知道,在oracle里面,存储过程里面可以传入数组(如int[]),也就是说,可以传多条记录到数据,从而一起更新。减少数据库的请求次数。 但SqlServer呢?bulk Insert这
我是一名优秀的程序员,十分优秀!