[INLONG-9982][Agent] Modify based on comments

apache · Apr 15, 2024 · e63799a · e63799a
1 parent 4b99136
commit e63799a
Showing 1 changed file with 1 addition and 10 deletions.
diff --git a/...gent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/sources/PulsarSource.java b/...gent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/sources/PulsarSource.java
@@ -130,16 +130,7 @@ private Consumer<byte[]> getConsumer() {
                 LOGGER.info("Skip to reset consume");
             }
             return consumer;
-        } catch (PulsarClientException e) {
-            if (consumer == null) {
-                try {
-                    consumer.close();
-                } catch (PulsarClientException ex) {
-                    LOGGER.error("close consumer error", e);
-                }
-            }
-            LOGGER.error("get consumer error", e);
-        } catch (IllegalArgumentException e) {
+        } catch (PulsarClientException | IllegalArgumentException e) {
             if (consumer == null) {
                 try {
                     consumer.close();