diff --git a/docs/guides/ingest-timeseries.mdx b/docs/guides/ingest-timeseries.mdx
index 2d41e82..cb0dbf0 100644
--- a/docs/guides/ingest-timeseries.mdx
+++ b/docs/guides/ingest-timeseries.mdx
@@ -290,7 +290,7 @@ sends once 10 000 points have accumulated or the oldest is 200 ms old. `add` nev
 network, and closing the buffer flushes what is left:
 
 ```java
-import ai.intellistream.datahub.sdk.ingest.BinaryIngestBuffer;
+import ai.intellistream.datahub.sdk.client.BinaryIngestBuffer;
 
 try (BinaryIngestBuffer buffer = client.timeseries().binaryBuffer()) {
     buffer.add("engine_temperature", Instant.now(), 92.4);
diff --git a/docs/guides/realtime-subscriptions.mdx b/docs/guides/realtime-subscriptions.mdx
index b78a4fb..303cb61 100644
--- a/docs/guides/realtime-subscriptions.mdx
+++ b/docs/guides/realtime-subscriptions.mdx
@@ -93,7 +93,7 @@ to the timeout and returns `null` on a quiet interval (it is a blocking queue ha
 **not** network polling):
 
 ```java
-import ai.intellistream.datahub.sdk.subscriptions.SubscriptionListener;
+import ai.intellistream.datahub.sdk.client.SubscriptionListener;
 import java.time.Duration;
 
 try (SubscriptionListener listener = client.subscriptions().listen(List.of("engine_room"))) {
diff --git a/docs/reference/subscriptions.md b/docs/reference/subscriptions.md
index 26db41b..0e0f950 100644
--- a/docs/reference/subscriptions.md
+++ b/docs/reference/subscriptions.md
@@ -154,7 +154,7 @@ Or drive `poll` yourself, a blocking queue hand-off (not network polling) that r
 to ack on your own schedule:
 
 ```java
-import ai.intellistream.datahub.sdk.subscriptions.SubscriptionListener;
+import ai.intellistream.datahub.sdk.client.SubscriptionListener;
 import java.time.Duration;
 
 try (SubscriptionListener listener = client.subscriptions().listen(List.of("engine_temps"))) {
diff --git a/docs/reference/timeseries.md b/docs/reference/timeseries.md
index 5caebf0..9cdd395 100644
--- a/docs/reference/timeseries.md
+++ b/docs/reference/timeseries.md
@@ -720,7 +720,7 @@ never blocks on the network; flushes run on a thread of their own. Python and Ru
 binary buffer: collect the readings and call `insert_datapoints_binary` yourself.
 
 ```java
-import ai.intellistream.datahub.sdk.ingest.BinaryIngestBuffer;
+import ai.intellistream.datahub.sdk.client.BinaryIngestBuffer;
 
 try (BinaryIngestBuffer buffer = client.timeseries().binaryBuffer()) {   // 10 000 points or 200 ms
     buffer.add("engine_temperature", Instant.now(), 92.4);