Don't fail in callback

streamnative · May 14, 2021 · e293791 · e293791
1 parent a3cae83
commit e293791
Showing 1 changed file with 1 addition and 3 deletions.
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
@@ -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());
                 }
             });
         }