diff --git a/docs/src/test/java-jdk9-only/jdocs/stream/operators/source/AsSubscriber.java b/docs/src/test/java-jdk9-only/jdocs/stream/operators/source/AsSubscriber.java
index 477ed82063e..bdaeafdc1d7 100644
--- a/docs/src/test/java-jdk9-only/jdocs/stream/operators/source/AsSubscriber.java
+++ b/docs/src/test/java-jdk9-only/jdocs/stream/operators/source/AsSubscriber.java
@@ -22,9 +22,6 @@
 import org.apache.pekko.stream.javadsl.JavaFlowSupport;
 
 //#imports
-
-import org.apache.commons.lang.NotImplementedException;
-
 public interface AsSubscriber {
     // We are 'faking' the JavaFlowSupport API here so we can include the signature as a snippet in the API,
     // because we're not publishing those (jdk9+) classes in our API docs yet.
@@ -42,13 +39,13 @@ static <T> org.apache.pekko.stream.javadsl.Source<T, Subscriber<T>> asSubscriber
 
     static class Row {
         public String getField(String fieldName) {
-            throw new NotImplementedException();
+            throw new UnsupportedOperationException("Not implemented in sample");
         }
     }
 
     static class DatabaseClient {
         Publisher<Row> fetchRows() {
-            throw new NotImplementedException();
+            throw new UnsupportedOperationException("Not implemented in sample");
         }
     }
 
diff --git a/docs/src/test/java-jdk9-only/jdocs/stream/operators/source/FromPublisher.java b/docs/src/test/java-jdk9-only/jdocs/stream/operators/source/FromPublisher.java
index 0a554762830..7dd0ec897bf 100644
--- a/docs/src/test/java-jdk9-only/jdocs/stream/operators/source/FromPublisher.java
+++ b/docs/src/test/java-jdk9-only/jdocs/stream/operators/source/FromPublisher.java
@@ -22,8 +22,6 @@
 
 //#imports
 
-import org.apache.commons.lang.NotImplementedException;
-
 public interface FromPublisher {
     // We are 'faking' the JavaFlowSupport API here so we can include the signature as a snippet in the API,
     // because we're not publishing those (jdk9+) classes in our API docs yet.
@@ -41,13 +39,13 @@ static <T> org.apache.pekko.stream.javadsl.Source<T, NotUsed> fromPublisher(Publ
 
     static class Row {
         public String getField(String fieldName) {
-            throw new NotImplementedException();
+            throw new UnsupportedOperationException("Not implemented in sample");
         }
     }
 
     static class DatabaseClient {
         Publisher<Row> fetchRows() {
-            throw new NotImplementedException();
+            throw new UnsupportedOperationException("Not implemented in sample");
         }
     }