Debezium PostgreSQL 连接器未创建主题

2023-12-05

当我使用启动 Debezium 连接器用于 PostgreSQL 时,未创建 Kafka 主题。这是我的属性文件中的内容:

name=testdb
connector.class=io.debezium.connector.postgresql.PostgresConnector
topic.prefix=test
database.hostname=localhost
database.port=5432
database.user=postgres
database.password=root
database.dbname=testdb
database.server.name=testdb
table.include.list=ipaddrs
plugin.name=pgoutput

根据this,主题应该命名testdb.myschema.ipaddrs (myschema是我的架构的名称)。然而bin/kafka-topics.sh --list --bootstrap-server 192.168.56.1:9092什么也不返回。如果我向表添加行,则不会创建主题ipaddrs.

当我运行时,Kafka 连接成功启动bin/connect-standalone.sh config/connect-standalone.properties config/postgres.properties无一例外。

I have auto.create.topics.enable = true. http://localhost:8083/connectors/testdb/status显示这个:

{"name":"testdb","connector":{"state":"RUNNING","worker_id":"10.0.0.48:8083"},"tasks":[{"id":0,"state":"RUNNING","worker_id":"10.0.0.48:8083"}],"type":"source"}

我没有运行 Zookeeper。我正在使用 KRaft 运行 Kafka。


table.include.list不正确。它必须包含架构。所以本来应该是myschema.ipaddrs在我的例子中。此外,该文档似乎不正确主题名称。在我的系统中是<topic.prefix>.<table name>。所以在我的例子中,它是test.myschema.ipaddrs.

本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系:hwhale#tublm.com(使用前将#替换为@)

Debezium PostgreSQL 连接器未创建主题 的相关文章

随机推荐

  • 父控制鼠标进入/离开子控件事件

    我有一个 C NET 2 0 WinForms 应用程序 我的应用程序有一个控件 它是两个子控件的容器 一个标签和某种编辑控件 你可以这样想 其中外框是父控件 Label Control Edit Control 我试图在鼠标进入或离开父控
  • 包含的 C++/C 头文件的实现在哪里?

    这可能看起来有点愚蠢 但这已经困扰了一段时间了 当我在我的C C程序中包含一些别人编写的头文件时 编译器如何知道头文件中声明的类成员函数的实现在哪里 假设我想编写一些利用 OpenCV 库的程序 通常我想使用 include
  • 具有多租户场景的 BackChannelLogoutUri

    我目前正在使用 Identity server 4 我正在尝试启用返回ChannelLogoutUri 每个客户端在客户端配置中都被赋予了一个 BackChannelLogoutUri BackChannelLogoutUri http l
  • 丰田 ECU 回复来自 MCP2515 和 Nodemcu-32s 的 0x03 0x7F 0x01 0x11 至 02 01 00 PID 查询请求

    我正在将 mcp2515 与 nodemcu 32s 一起使用 并且能够接收互联网上几乎没有 2c4 2c1 340 等 id 的消息 我看到 2c4 用于 rpm 我也验证了它 我的问题是 无论我使用哪个库来请求支持的 pid 支持的 p
  • C++0x 闭包的未定义行为:I

    考虑这个例子 include
  • 无法将 Glassfish 服务器添加到 Netbeans IDE 14

    正如标题所示 我无法将 Glassfish 服务器添加到 NetBeans IDE 14 我按下了 添加服务器 菜单项 然后在 选择服务器 屏幕上选择了 GlassFish 服务器 然后 显示 不是有效的 GlassFish Server
  • 字体未加载

    我在我的网站中使用了一些服装字体 但我遇到了一个问题 它没有加载 我无法找出问题所在 代码如下 font face font family OuachitaWayWbw src url fonts Ouachita Way Wbw ttf
  • 缓存高效的矩阵转置程序?

    因此转置矩阵的明显方法是使用 for int i 0 i lt n i for int j 0 j lt n j destination j i n source i j n 但我想要一些能够利用局部性和缓存阻塞的东西 我正在查找它 但找不
  • 在 R 中使用 idw 的空间插值误差

    我正在尝试按纬度和经度对海水 pH 值数据集进行空间插值 sample lt read csv file Station locations 2016 csv header TRUE sep strip white T head sampl
  • React Native 上传图片失败

    在过去的两天里 我一直在努力破解使用 React Native 到 MongoDB 的文件 图像上传 我确实阅读了所有相关论坛 但没有运气 我阅读了几个论坛 他们给出了一个示例 但我没有成功 这是我编写的示例代码 客户端 const uri
  • ASP.NET MVC 3:使用 TextBoxFor 覆盖“名称”属性

    使用时可以吗Html TextBoxFor覆盖名称属性 我尝试过但没有成功 我需要使用 TextBoxFor 来使客户端验证正常工作 但是由于我不会详细说明的原因 我需要文本框的名称与生成的名称不同 我已经尝试过以下方法 Html Text
  • 如何使用 Tampermonkey 删除 CSS 类?

    我对 CSS 和 javascript 很陌生 所以别着急 我正在尝试删除课程disable stream来自 div class stream notifications 下的每个 div 元素 见下图 我在 Tampermonkey 中
  • active-record postgres 检查 jsonb 数组是否包含 x 或 y

    我有一个带有 jsonb 列的表 其中有一个嵌套的 json 数组 我想找到嵌套数组至少包含一个值的所有记录 例如 我的模型 Person 有一个名为preferences 的 jsonb 列 在 jsonb 首选项中 有几个键 其中一个值
  • 为什么我的 IE MIME 过滤器没有被创建或调用?

    我正在尝试创建一个 MIME 过滤器 以在将网页接收的资源传递到 Windows 应用程序中的 Web 浏览器控件之前对它们进行一些自定义处理 该应用程序是用 C 编写的 如果可能的话 我也想用托管代码编写 MIME 过滤器 不过我遇到了麻
  • 我想使用 dompdf 循环创建多个 pdf?

    我想使用 dompdf 循环生成多个 pdf 文件 我正在使用 dompdf 0 6 0 beta3 但每次执行代码时只会生成一个文件 我提供我的代码供参考 如下 include dompdf config inc php for i 0
  • 将图像垂直对齐到引导“列”内的底部?

    我正在尝试垂直对齐img to the bottom包含 Bootstrap 的column 如何才能做到这一点 Example div class container fluid style background color 00ff00
  • 包含 PHP 脚本时传递参数

    我想这样做 但它给出了错误 为了更好地理解我的问题 我举了一个例子 script php 的内容 那么 如何在包含脚本页面的同时传递参数 你可以设置 GET text 在包含文件之前 GET text hiii include script
  • 屏幕尺寸蜂窝菜单 android

    您好 我正在尝试获取屏幕的屏幕尺寸减去底部的菜单栏 我知道我可以根据设备的分辨率减去一个常数 但这是一个超级丑陋的黑客 我相信谷歌的人不会愚蠢到忘记给用户一个函数来获取底部菜单栏的高度 这样我就可以从全屏尺寸中减去它 这是一个类似的帖子 A
  • Java 进程可以删除加载的 JAR 吗?

    您好我有以下问题 在卸载过程中 我加载一个 JAR jdbc 驱动程序 URL pDriverJar jarToDelete toURI toURL URL lURLList new URL pDriverJar URLClassLoade
  • Debezium PostgreSQL 连接器未创建主题

    当我使用启动 Debezium 连接器用于 PostgreSQL 时 未创建 Kafka 主题 这是我的属性文件中的内容 name testdb connector class io debezium connector postgresq