kafka connect为ksqldb调试重新读取整个文件,还是ksqldb可能在创建查询后插入所有事件?

0ejtzxu1  于 2021-07-15  发布在  Kafka
关注(0)|答案(1)|浏览(300)

我开始与ksqldb和kafka connect一起开发。Kafka连接是可怕的,一切都很好,并有行为不重读记录,如果它检测到它已经在过去读取(极为有用的生产)。但是,对于ksqldb查询的开发和调试,有必要重放数据,因为ksqldb将在发出更改时动态创建表条目。如果没有重放任何内容,则“test”查询将保持为空。第一次插入csv文件后,如何用kafka connect重放该文件,有什么建议吗?也许,ksqldb有可能在创建表之后重新阅读整个主题。有人能给初学者一个答案吗?

oxf4rvwz

oxf4rvwz1#

使用其他名称创建源连接器,或为csv文件指定新名称。两者都应该引起重新阅读。

相关问题