This repository was archived by the owner on Oct 7, 2022. It is now read-only.
This repository was archived by the owner on Oct 7, 2022. It is now read-only.
Synchronous flush #8
Open
Description
KAFKA_CONSUMER_BATCH_SIZE controls when the in-memory events are flushed to ES.
However some topics may have small throughput, not having their events flushed at all.
It would be nice to have a second parameter controlling a recurrent tick so the in-memory events are flushed even when they do not meet the batch size requirement
Metadata
Metadata
Assignees
Labels
No labels