diff --git a/tests/src/test/java/io/streamnative/pulsar/handlers/kop/DifferentNamespaceTestBase.java b/tests/src/test/java/io/streamnative/pulsar/handlers/kop/DifferentNamespaceTestBase.java index ae46e24648..59d5dfbe23 100644 --- a/tests/src/test/java/io/streamnative/pulsar/handlers/kop/DifferentNamespaceTestBase.java +++ b/tests/src/test/java/io/streamnative/pulsar/handlers/kop/DifferentNamespaceTestBase.java @@ -15,7 +15,6 @@ import static org.testng.Assert.assertEquals; import static org.testng.Assert.assertTrue; -import static org.testng.Assert.fail; import com.google.common.collect.Sets; import io.streamnative.pulsar.handlers.kop.utils.KopTopic; @@ -99,8 +98,7 @@ void testSimpleProduceAndConsume(String topic) { log.info("Successfully send {} to {}-partition-{}", key, recordMetadata.topic(), recordMetadata.partition()); } else { - log.error("Failed to send {}", key); - fail("Failed to send " + key); + log.error("Failed to send {}: {}", key, e.getMessage()); } }); }