Flush buffer if not full but some time has gone by (safety net for low frequency input)
mre opened this issue · 3 comments
mre commented
Kafka-Python comes with a message consumer that allows this.
mre commented
As suggested by @IngaFeick
IngaFeick commented
+4711
mre commented
This is already handled by kafka-python, so nothing to do anymore.