diff --git a/kafka-client/src/main/java/dev/responsive/kafka/internal/clients/OriginEventRecorderImpl.java b/kafka-client/src/main/java/dev/responsive/kafka/internal/clients/OriginEventRecorderImpl.java
index 12419ebc1..5346698d4 100644
--- a/kafka-client/src/main/java/dev/responsive/kafka/internal/clients/OriginEventRecorderImpl.java
+++ b/kafka-client/src/main/java/dev/responsive/kafka/internal/clients/OriginEventRecorderImpl.java
@@ -235,7 +235,8 @@ public void accept(final Map<TopicPartition, Integer> counts, final String threa
 
       try {
         final HttpRequest request = HttpRequest.newBuilder()
-            .uri(new URI(licenseServer + "/usage"))
+            .version(HttpClient.Version.HTTP_1_1)
+            .uri(new URI(licenseServer + "/v1/usage"))
             .header("Content-Type", "application/json")
             .header("Authorization", "Bearer " + apiKey)
             .POST(HttpRequest.BodyPublishers.ofString(mapper.writeValueAsString(body)))
diff --git a/kafka-client/src/test/java/dev/responsive/kafka/testutils/TestLicenseServer.java b/kafka-client/src/test/java/dev/responsive/kafka/testutils/TestLicenseServer.java
index 626ec37cf..903f5c61f 100644
--- a/kafka-client/src/test/java/dev/responsive/kafka/testutils/TestLicenseServer.java
+++ b/kafka-client/src/test/java/dev/responsive/kafka/testutils/TestLicenseServer.java
@@ -41,7 +41,7 @@ public synchronized void start() throws IOException {
     LOG.info("Starting test license server...");
     // Create a server on a random available port (port 0 means OS-assigned)
     server = HttpServer.create(new InetSocketAddress(0), 0);
-    server.createContext("/usage", exchange -> {
+    server.createContext("/v1/usage", exchange -> {
       final var body = exchange.getRequestBody();
       final var req = MAPPER.readValue(body, OriginEventsReportRequestV1.class);