SOLO

0 声望

这家伙太懒，什么都没留下

个人动态
  • 半兽人 回复 SOLO 在 Kafka Connector开发指南 中 ：

    没有找到SourceConnector实现匹配，类似以下的实现：

    extends SourceConnector
    2年前
  • 半兽人 回复 SOLO 在 Kafka Streams开发者指南 中 ：

    实践是检验的唯一真理

    2年前
  • SOLO 回复 SOLO 在 Kafka Streams开发者指南 中 ：

    join的结果是一纵列的合集。

    2年前
  • SOLO 回复 半兽人 在 Kafka Connector开发指南 中 ：

    大佬你好，我原原本本把kafka down到本地，然后照着大佬的讲解run了几个简单的例子，topic之间发了几个消息，都运行正常。但尝试connector file导入/导出数据，运行命令

    bin/connect-standalone.sh config/connect-standalone.properties config/connect-file-source.properties config/connect-file-sink.properties

    出现下面错误，找不到FileStreamSourceConnector，我是哪个文件放错目录了吗？劳烦请指点一下，谢谢。

    ERROR Failed to create job for config/connect-file-source.properties (org.apache.kafka.connect.cli.ConnectStandalone:107)
    ERROR Stopping after connector error (org.apache.kafka.connect.cli.ConnectStandalone:117)
    java.util.concurrent.ExecutionException: org.apache.kafka.connect.errors.ConnectException: Failed to find any class that implements Connector and which name matches FileStreamSourceConnector

    2年前
  • 赞了 Kafka Connector开发指南 · 2年前
  • SOLO 回复 半兽人 在 Kafka Streams开发者指南 中 ：

    你好，官网上https://kafka.apache.org/32/documentation/streams/developer-guide/dsl-api.html#joining 对Left (KStream) Right (KStream)各种join的表格例子，里面随着timestamp + +，而产生的join结果，应该是增量吧？即到window time out时，产出的结果应该是整个一纵列的结果合集。不知道理解的对不对，望指点。
    我自己想试着在本地运行一下看看，但是小白一个，还没跑起来。

    2年前