SOLO

0 声望

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

个人动态
  • 半兽人 回复 SOLOKafka Connector开发指南 中 :

    没有找到SourceConnector实现匹配,类似以下的实现:

    extends SourceConnector
    
    1年前
  • 半兽人 回复 SOLOKafka Streams开发者指南 中 :

    实践是检验的唯一真理

    1年前
  • SOLO 回复 SOLOKafka Streams开发者指南 中 :

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

    1年前
  • 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

    1年前
  • 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时,产出的结果应该是整个一纵列的结果合集。不知道理解的对不对,望指点。
    我自己想试着在本地运行一下看看,但是小白一个,还没跑起来。

    1年前