当前位置: 首页 > 知识库问答 >
问题:

汇流复制器无法在目标kafka服务器上复制数据

孔海超
2023-03-14

我已经在两个不同的主机上安装了融合Kafka,并尝试让融合复制器工作。我已经完全遵循了本教程中提到的内容。

当我启动复制器时,我没有看到任何错误,这是我看到的日志:

WorkerSourceTask { id = Replicator-source-0 }正在提交偏移量(org . Apache . Kafka . connect . runtime . WorkerSourceTask:397)[2019-03-26 06:38:15,049]INFO WorkerSourceTask { id = Replicator-source-0 }正在为偏移量提交刷新0条未完成的消息(org . Apache . Kafka . connect . runtime . WorkerSourceTask:414)

我尝试在两台kafka服务器主机上运行replicator我希望复制器在目标服务器上复制数据

共有1个答案

洪越泽
2023-03-14

我犯的错误是我在connect-standalone.properties.中有源Kafka值,但它应该是目标Kafka。

 类似资料:
  • 我建立了两台服务器:第一台用于前端(localhost:7200),第二台用于后端(localhost:7300)。相应地,在路由“/test”上,前端到后端发出了一个测试请求。 问题在于,当我发送一个json对象(单击“btn”按钮时)时,它会拒绝,并显示以下消息: CORS策略阻止从http://localhost:7300/testhttp://localhost:7200访问XMLHttp

  • 我似乎是一个简单的任务,但我需要SQL专家的一些帮助。 联系人的数量可以从1人到30人不等,我希望每个cust\u ref的所有电话号码都排在一行。 我怎么能这样做??

  • 问题内容: 我想要类似的东西: 这两个表是完全相同的。 如何 在两个服务器实例之间复制数据? 问题答案: SQL-链接服务器 如果两个服务器都是SQL Server,则可以设置链接服务器-为了安全起见,我建议使用一个SQL帐户。 然后,您可以简单地执行 如果您在连接到server1的SQL Management Studio中运行查询,并且当前数据库设置为database1,则不需要前缀 同样,链

  • 我在Spring上有一个拦截器,可以拦截用户的请求。我想计算申请的持续时间并保存到数据库中。然而,Spring不会自动连接我的豆子,导致服务上的空点异常。 这是代码: 我如何避免这个NPE?

  • 我有副本和主人工服务器。我已经成功地为许多不同的软件包(maven、npm、bower等)设置了复制。我很难在副本服务器上为docker存储库设置拉复制。 我可以在web浏览器中列出带有存储库结构的URL及其文件夹: 这列出了一个文件夹,我在该回购。我正在使用管理员用户访问。但是,如果我尝试在JFROG Artifictory UI中设置此URL,我会收到以下消息: 我也发现了这个链接:https

  • mysql服务器有可能同时是主服务器和从服务器吗?我希望server1成为db1的主服务器(server2作为db1的从服务器运行)此外,我希望server1成为db2的从服务器(server2作为db2的主服务器)。这能做到吗?