|
|
@@ -83,6 +83,8 @@
|
|
|
| bufferPageSize | int: 默认值为全局配置 | 缓冲页是批量读/写到磁盘的单位，以防止频繁的IO。如果页面未满，eKuiper 因硬件或软件错误而崩溃，最后未写入磁盘的页面将被丢失。 |
|
|
|
| resendInterval | int: 默认值为全局配置 | 故障恢复后重新发送信息的时间间隔，防止信息风暴。 |
|
|
|
| cleanCacheAtStop | bool: 默认值为全局配置 | 是否在规则停止时清理所有缓存，以防止规则重新启动时对过期消息进行大量重发。如果不设置为true，一旦规则停止，内存缓存将被存储到磁盘中。否则，内存和磁盘规则会被清理掉。 |
|
|
|
+| batchSize | int: 0 | 设置缓存发送的消息数目。sink将阻塞消息发送，直到缓存的消息数目等于该值后，再将该数目的消息一次性发送。batchSize 将对 []map 的数据视为多条数据。 |
|
|
|
+| lingerInterval | int 0 | 设置缓存发送的间隔时间，单位为毫秒。sink将阻塞消息发送，直到缓存发送的间隔时间达到该值后。lingerInterval 可以与 batchSize 一起使用，任意条件满足时都会触发发送。 |
|
|
|
|
|
|
|
|
|
### 动态属性
|
yisaer