diff --git a/requirements.txt b/requirements.txt
index cd78754a..c13e631b 100644
--- a/requirements.txt
+++ b/requirements.txt
@@ -2,7 +2,7 @@ aiohttp>=3.12.15
 asn1crypto>=1.5.0
 build>=1.3.0
 click>=8.1.0
-confluent-kafka>=2.9.0,<2.10.0
+confluent-kafka>=2.13.2
 cryptography>=45.0.7
 datadog==0.52.1
 google-api-core==2.25.1
@@ -16,9 +16,9 @@ protobuf>=5.29.5,<6
 pydantic>=2.9.2,<2.10.0
 pyyaml>=6.0
 rich>=14.1.0
-sentry-arroyo==2.34.0
+sentry-arroyo>=2.38.7
 sentry-sdk>=2.36.0
 sortedcontainers>=2.4.0
-taskbroker-client>=0.1.5
+taskbroker-client>=0.1.9,<1
 typing-extensions>=4.15.0
 zipfile-zstd==0.0.4
diff --git a/src/launchpad/worker/app.py b/src/launchpad/worker/app.py
index 75976c36..c46c07ea 100644
--- a/src/launchpad/worker/app.py
+++ b/src/launchpad/worker/app.py
@@ -51,6 +51,18 @@ def distribution(
             kwargs["sample_rate"] = sample_rate
         self._dogstatsd.distribution(name, value, **kwargs)
 
+    def gauge(
+        self,
+        name: str,
+        value: int | float,
+        tags: Tags | None = None,
+        sample_rate: float | None = None,
+    ) -> None:
+        kwargs: dict = {"tags": _convert_tags(tags)}
+        if sample_rate is not None:
+            kwargs["sample_rate"] = sample_rate
+        self._dogstatsd.gauge(name, value, **kwargs)
+
     @contextmanager
     def timer(
         self,