Merge pull request #1214 from thunderstore-io/add-kafka-poll

MythicManiac · web-flow · commit ef96a825501b · 2025-12-10T11:38:11.000+02:00
Added poll call to properly handle kafka internal queue
diff --git a/django/thunderstore/ts_analytics/kafka.py b/django/thunderstore/ts_analytics/kafka.py
@@ -69,6 +69,7 @@ def _send_string(
                 value=value_bytes,
                 key=key_bytes,
             )
+            self._producer.poll()
         except Exception as e:  # pragma: no cover
             capture_exception(e)
 

Original file line number	Diff line number	Diff line change
`@@ -69,6 +69,7 @@ def _send_string(`
`69`	`69`	`value=value_bytes,`
`70`	`70`	`key=key_bytes,`
`71`	`71`	`)`
	`72`	`+ self._producer.poll()`
`72`	`73`	`except Exception as e: # pragma: no cover`
`73`	`74`	`capture_exception(e)`
`74`	`75`