debezium postgresql连接器table.include.slist config Change时未更新
我在连接器中更新table.include.list有一个问题。 当我最初运行连接器时,一切正常。我在公共模式中有2个PSQL表:CN_ODER,dbz_signal。
curl -i -X POST -H "Content-Type:application/json" \
http://localhost:8083/connectors \
-d ' {
"name": "inventory-connector",
"config": {
"connector.class": "io.debezium.connector.postgresql.PostgresConnector",
"tasks.max": "1",
"database.hostname": "XXX.internal",
"database.port": "5434",
"database.user": "debezium_user",
"database.password": "passwordXXX",
"database.dbname" : "cn_db",
"database.server.name": "myinstance",
"schema.include": "public",
"table.include.list": "public.cn_order,public.dbz_signal",
"signal.data.collection": "public.dbz_signal",
"plugin.name":"pgoutput",
"publication.autocreate.mode":"filtered",
}
}'
然后,我添加一个新表(具有相同特权,与CN_Order相同的特权)CN_USER 但是,在将此表添加后 public.cn_user 到table.include.list。 /代码> 并发送连接器配置更新请求
curl -i -X PUT -H "Accept:application/json" -H "Content-Type:application/json" \
http://localhost:8083/connectors/inventory-connector/config \
-d '{...the same as the config before only table.include.list updated as mentioned above...}'
我的消费者主题myinstance.public.cn_user不会获取任何流数据,当我将行插入public.cn_user时
,我的消费者主题会获取过去的数据,如果我发送快照信号
sql = "INSERT INTO public.dbz_signal VALUES ('signal-1', 'execute-snapshot', '{\"data-collections\": [\"public.cn_user\"]}')"
,但是没有流数据...
有人以前经历过吗?任何建议将不胜感激。谢谢。
I have an issue with updating table.include.list in my connector.
When I initially run my connector everything works okay. I have 2 psql tables in public schema: cn_oder, dbz_signal.
curl -i -X POST -H "Content-Type:application/json" \
http://localhost:8083/connectors \
-d ' {
"name": "inventory-connector",
"config": {
"connector.class": "io.debezium.connector.postgresql.PostgresConnector",
"tasks.max": "1",
"database.hostname": "XXX.internal",
"database.port": "5434",
"database.user": "debezium_user",
"database.password": "passwordXXX",
"database.dbname" : "cn_db",
"database.server.name": "myinstance",
"schema.include": "public",
"table.include.list": "public.cn_order,public.dbz_signal",
"signal.data.collection": "public.dbz_signal",
"plugin.name":"pgoutput",
"publication.autocreate.mode":"filtered",
}
}'
Then I add a new table (with the same privileges, owernship as cn_order) cn_user
However, after adding this table public.cn_user to table.include.list so it becomes "table.include.list": "public.cn_order,public.cn_user,public.dbz_signal"
and send the connector config update request
curl -i -X PUT -H "Accept:application/json" -H "Content-Type:application/json" \
http://localhost:8083/connectors/inventory-connector/config \
-d '{...the same as the config before only table.include.list updated as mentioned above...}'
my consumer topic myinstance.public.cn_user doesn't get any streaming data, when I insert the rows to public.cn_user
However, the my consumer topic gets the past data, if I send a snapshot signal
sql = "INSERT INTO public.dbz_signal VALUES ('signal-1', 'execute-snapshot', '{\"data-collections\": [\"public.cn_user\"]}')"
but no streaming data...
Did anyone experience this before? Any advice is appreciated. Thanks.
如果你对这篇内容有疑问,欢迎到本站社区发帖提问 参与讨论,获取更多帮助,或者扫码二维码加入 Web 技术交流群。

绑定邮箱获取回复消息
由于您还没有绑定你的真实邮箱,如果其他用户或者作者回复了您的评论,将不能在第一时间通知您!
发布评论