汇流复制器无法在目标kafka服务器上复制数据
我已经在两个不同的主机上安装了融合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个答案
我犯的错误是我在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
-
问题内容： 我正在尝试使用http客户端通过为单个主机设置最大连接来访问服务器 HttpParams httpParam = httpclient.getParams（）; HttpConnectionParams.setSoTimeout（httpParam，SOCKET_TIMEOUT）; 那就是我们使用连接池来实现http持久性。 我们偶尔会收到此错误： 有谁知道如何解决这个问题？ 我们也将