There was an error while loading. Please reload this page.
1 parent c455667 commit df0b65eCopy full SHA for df0b65e
1 file changed
src/imas_streams/kafka.py
@@ -26,7 +26,11 @@
26
_INITIAL_BACKOFF_TIME = 0.02 # seconds
27
_MAXIMUM_BACKOFF_TIME = 1.0 # seconds
28
_STREAMING_HEADER_KEY = "streaming-imas-metadata"
29
-_FETCH_WAIT_MAX_MS = 50
+# Kafka server will wait maximal _FETCH_WAIT_MAX_MS before sending new messages to the
30
+# consumer. Adjusted from the default (500ms) to decrease latency, especially when using
31
+# "most_recent_only" since a seek() needs to wait at least this amount of time before it
32
+# is effective (see KafkaConsumer._fast_forward()).
33
+_FETCH_WAIT_MAX_MS = 50 # milli-seconds
34
35
36
class KafkaSettings(BaseModel):
0 commit comments