在特定时间段后创建新文件

klr1opcd  于 2021-06-07  发布在  Kafka
关注(0)|答案(0)|浏览(236)

我有一条 Camel 路线,从Kafka源源不断地穿过。是否有某种方法可以定义每10分钟创建一个新文件?我需要每个文件有不同的名称,因为当一个文件不能有相同的名称作为其他。我尝试过计时器和石英 Camel 组件,但没有成功。

from("kafka:testTopic?brokers=localhost:9092&groupId=01")
.to("file:C://DESTINATION?fileExist=Append&fileName=prefixName_${variable}.json");

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题