我想每小时刷新kafka主题中的所有记录，以下哪个属性有帮助，以便到达主题中一小时的数据在文件或分区中完全可用？
我了解到，在中断期间，rotate schedule interval只中断了一个语义？这是否意味着在使用时没有提交回kafka connect的偏移量 rotate.schedule.interval.ms 以及 rotate.interval.ms 不刷新主题中的所有数据？
这些属性是否支持一次语义 rotate.interval.ms and TimeBasedpartitioner 也？
谢谢您！！