apache-kafka - Confluent 复制器无法在目标 kafka 服务器上复制数据
问题描述
我已经在两个不同的主机上安装了 confluent Kafka 并尝试使 confluent 复制器工作。我严格按照本教程中提到的内容进行操作。
启动复制器时没有看到任何错误,这是我看到的日志:
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 服务器主机上运行复制器;我希望该复制器能够在目标服务器上复制数据
解决方案
我犯的错误是我在 connect-standalone.properties 中有源 kafka 值。但它应该是目的地卡夫卡。
推荐阅读
- javascript - 像异步操作的当前状态这样的东西应该存储在 react-redux 应用程序中的什么位置?
- android - 如果已部署应用程序,Android 上的 Xamarin Forms 调试将无法启动
- php - 使用 ajax 填充文本框
- node.js - 从 Firebase 获取数据 - Google Cloud Functions
- shell - 我需要获取按行比较文件并列出差异的脚本
- objective-c - 如何获取 uitableviewcell 的 detailtextlabel 的默认 CGRECT 尺寸?
- java - 我们如何验证运行 ElasticSearch 的堆大小
- swift3 - SpriteKit 的滚珠和转动效果
- python - 仅搜索混合字段中的数字 (elasticsearch)
- sql - 这行代码是什么意思???(新的编程!)