catch test

eo-cqrs · Jun 21, 2023 · 1810a74 · 1810a74
1 parent af4ba15
commit 1810a74
Showing 1 changed file with 21 additions and 0 deletions.
diff --git a/src/test/java/io/github/eocqrs/kafka/fake/FkConsumerTest.java b/src/test/java/io/github/eocqrs/kafka/fake/FkConsumerTest.java
@@ -220,6 +220,27 @@ void throwsIfNull() {
     );
   }
 
+  @Test
+  void throwsIfNullWithListener() {
+    final Consumer<String, String> consumer =
+      new FkConsumer<>(
+        UUID.randomUUID(),
+        this.broker
+      );
+    Assertions.assertThrows(
+      IllegalStateException.class,
+      () -> consumer.subscribe(new ConsumerRebalanceListener() {
+        @Override
+        public void onPartitionsRevoked(final Collection<TopicPartition> collection) {
+        }
+
+        @Override
+        public void onPartitionsAssigned(final Collection<TopicPartition> collection) {
+        }
+      }, (String) null)
+    );
+  }
+
   @Test
   void createsFakeConsumer() {
     final FkConsumer<String, String> consumer =