小编Bün*_*ürk的帖子

Kafka Connect 访问架构注册表的基本身份验证

我们已将架构注册表和 Kafka Connect 设置为使用基本身份验证。一些连接器似乎正在运行。但其中一些给出了错误:

“io.confluence.kafka.schemaregistry.client.rest.exceptions.RestClientException:未经授权;错误代码:401”

如何向 Kafka Connect 提供架构注册表的凭据?我应该在连接器配置或 connect-distributed.properties 中定义它吗?请注意,我可以毫无问题地使用 GET 等curl 命令。

rest apache-kafka apache-kafka-connect confluent-schema-registry

4
推荐指数
1
解决办法
3135
查看次数

2 个 Debezium 连接器可以同时从同一源读取数据吗?

正如标题所示,我有 2 个独立的服务器,我希望两个连接器从同一源读取数据以写入各自的主题。单个连接器效果很好。当我在另一台服务器中创建另一个服务器时,它们似乎正在运行,但两者都没有发生数据流。我的问题是,是否可以运行 2 个从同一源读取数据的 Debezium 连接器?我在文档中找不到有关此主题的任何信息。

编辑:我用 oracle 数据库测试过它,但从未见过它运行良好。绝对不建议使用它,尤其是在 oracle 中。

apache-kafka debezium

4
推荐指数
1
解决办法
3043
查看次数