We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 884d8d4 commit 921942dCopy full SHA for 921942d
tests/src/test/java/io/streamnative/pulsar/handlers/kop/KafkaTopicConsumerManagerTest.java
@@ -512,7 +512,9 @@ public void testUnloadTopic() throws Exception {
512
topicConsumerManager.removeCursorFuture(totalMessages - 1).get();
513
fail("should have failed");
514
} catch (ExecutionException ex) {
515
- assertTrue(ex.getCause().getMessage().contains("Current managedLedger has been closed."));
+ log.info("error", ex);
516
+ assertTrue(ex.getCause().getMessage().contains("Current managedLedger for "
517
+ + fullTopicName + " has been closed."));
518
}
519
520
0 commit comments