使用选定列更改表-debezium抛出ArrayIndexOutOfBoundsException
CDC表的列数少于源表。当debezium试图在Kafka中创建一个事件时，它失败了：
ArrayIndexOutOfBounds异常。
历史主题包含完整源表架构的快照。这是否是debezium的一个限制，即CDC模式不能与源模式不同？
This connector will be stopped.\n\tat io.debezium.connector.base.ChangeEventQueue.throwProducerFailureIfPresent(ChangeEventQueue.java:170)\n\tat
io.debezium.connector.base.ChangeEventQueue.poll(ChangeEventQueue.java:151)\n\tat io.debezium.connector.sqlserver.SqlServerConnectorTask.poll(SqlServerConnectorTask.java:158)\n\tat
org.apache.kafka.connect.runtime.WorkerSourceTask.poll(WorkerSourceTask.java:245)\n\tat org.apache.kafka.connect.runtime.WorkerSourceTask.execute(WorkerSourceTask.java:221)\n\tat
org.apache.kafka.connect.runtime.WorkerTask.doRun(WorkerTask.java:175)\n\tat org.apache.kafka.connect.runtime.WorkerTask.run(WorkerTask.java:219)\n\tat
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515)\n\tat java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264)\n\tat
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)\n\tat java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)\n\tat
java.base/java.lang.Thread.run(Thread.java:834)\nCaused by: java.lang.ArrayIndexOutOfBoundsException: Index 10 out of bounds for length 10\n\tat io.debezium.relational.TableSchemaBuilder.lambda$createValueGenerator$2(TableSchemaBuilder.java:210)\n\tat
io.debezium.relational.TableSchema.valueFromColumnData(TableSchema.java:135)\n\tat io.debezium.relational.RelationalChangeRecordEmitter.emitUpdateRecord(RelationalChangeRecordEmitter.java:89)\n\tat
io.debezium.relational.RelationalChangeRecordEmitter.emitChangeRecords(RelationalChangeRecordEmitter.java:46)\n\tat
io.debezium.pipeline.EventDispatcher.dispatchDataChangeEvent(EventDispatcher.java:125)\n\tat
io.debezium.connector.sqlserver.SqlServerStreamingChangeEventSource.lambda$execute$1(SqlServerStreamingChangeEventSource.java:203)\n\tat
io.debezium.jdbc.JdbcConnection.prepareQuery(JdbcConnection.java:485)\n\tat
io.debezium.connector.sqlserver.SqlServerConnection.getChangesForTables(SqlServerConnection.java:143)\n\tat
io.debezium.connector.sqlserver.SqlServerStreamingChangeEventSource.execute(SqlServerStreamingChangeEventSource.java:137)\n\tat
io.debezium.pipeline.ChangeEventSourceCoordinator.lambda$start$0(ChangeEventSourceCoordinator.java:86)\n\t... 5 more\n"}],"type":"source"}```
共有1个答案
捕获表必须捕获源表中定义的所有列。
有一个WIP PRhttps://github.com/debezium/debezium/pull/748可以消除这个限制。
-
我正在使用Debezium(0.7.5)MySQL连接器，我试图了解如果我想使用选项更新此配置，那么最好的方法是什么。 假设我创建了一个连接器，如下所示： 过了一段时间（2周），我需要将一个新表()添加到这个选项中（而且这个表是一个旧表，它是在连接器之前创建的） 我尝试的是： 暂停连接器。 删除了历史主题（也许这就是问题所在？）。 通过API update config Endpoint更新了配置
-
问题内容： 我有一个带有已知值的下拉列表。我想做的是使用 jQuery 将下拉列表设置为一个我知道存在的特定值。使用常规 JavaScript，我将执行以下操作： 但是，我需要使用 jQuery 来完成此操作，因为我为选择器使用了 CSS类愚蠢的[ASP.NET客户端ID …）。 这是我尝试过的一些方法： 如何使用 jQuery ？ 更新资料 事实证明，我第一次做对了： 当我在上面放置一个警报时，
-
问题内容： 我有两个选择： 如果我首先选择“水果”，该如何使用jQuery？第二个选择仅向我显示水果- 香蕉，苹果，橙子。如果我在第一个选择中选择“鸟”，则第二个选择仅显示“鸟”-老鹰，鹰。等等… 我试图用这段jQuery代码来做到这一点： 不幸的是，它几乎删除了所有内容，而且我不知道如何恢复一些选择。我也阅读了一些有关克隆的内容，但是在这种情况下我不知道如何使用它。 问题答案： $(“#sele
-
问题内容： 我有非常简单的代码： 我通过list.add（0，d）得到ConcurrentModificationException异常。所以总的来说，这是因为sublist（）造成的。我很困惑，因为在sublist（）的情况下，文档中说： 返回列表由该列表支持，因此返回列表中的非结构性更改会反映在此列表中， 反之亦然 。 您能解释一下渔获量在哪里吗？ 问题答案： 这是原始列表的简单视图（请参阅此
-
问题内容： 我有这样的选项菜单： 现在，我想使用href更改选定的选项。例如： 但是我想用而不是选择选项。 如何更改此代码？ 问题答案： 更改 至
-
使用debezium从Postgres流式更改 已完成的设置: Docker设置。 启动Postgres、zookeeper、kafka和debezium Connector。 使用decoderbufs、wal2json(postgres)设置远程数据库。 使用curl连接到debezium。 创建了一个观察者。 问题：当我启动watcher时，它读取了之前发生的所有更改，但当任何插入完成时，k