add a delay config like linger.ms in kafka producer - Githubissues

vesoft-inc / nebula-flink-connector

Flink Connector for Nebula Graph

48 stars 30 forks source link

add a delay config like linger.ms in kafka producer #29

Closed HarrisChu closed 2 years ago

HarrisChu commented 2 years ago

refer to https://docs.confluent.io/platform/current/installation/configuration/producer-configs.html#producerconfigs_linger.ms

default: 0, no delay. if has value, although the record is not reach batch size, send them immediately.

Nicole00 commented 2 years ago

https://github.com/vesoft-inc/nebula-flink-connector/pull/33 resolved it.