我有一条 Camel 路线,从Kafka源源不断地穿过。是否有某种方法可以定义每10分钟创建一个新文件?我需要每个文件有不同的名称,因为当一个文件不能有相同的名称作为其他。我尝试过计时器和石英 Camel 组件,但没有成功。
from("kafka:testTopic?brokers=localhost:9092&groupId=01")
.to("file:C://DESTINATION?fileExist=Append&fileName=prefixName_${variable}.json");
暂无答案!
目前还没有任何答案,快来回答吧!