Update ContextImpl.java

nikam14 · Sep 26, 2024 · 5cdb582 · 5cdb582
1 parent 32967db
commit 5cdb582
Showing 1 changed file with 5 additions and 3 deletions.
diff --git a/...ar-functions/instance/src/main/java/org/apache/pulsar/functions/instance/ContextImpl.java b/...ar-functions/instance/src/main/java/org/apache/pulsar/functions/instance/ContextImpl.java
@@ -721,7 +721,8 @@ public void setInputConsumers(List<Consumer<?>> inputConsumers) {
                         topicConsumers.putIfAbsent(TopicName.get(consumer.getTopic()), consumer);
                         if (consumer.getTopic().contains("-partition-")) {
                             partionedTopicPresent = true;
-                        }});
+                        }
+                });
     }
 
     private void reloadConsumersFromMultiTopicsConsumers() {
@@ -738,7 +739,8 @@ private void reloadConsumersFromMultiTopicsConsumers() {
                          topicConsumers.putIfAbsent(TopicName.get(c.getTopic()), c);
                          if (c.getTopic().contains("-partition-")) {
                             partionedTopicPresent = true;
-                         }});
+                         }
+                });
     }
 
     // returns null if consumer not found
@@ -761,7 +763,7 @@ Consumer<?> getConsumer(String topic, int partition) throws PulsarClientExceptio
             throw new PulsarClientException("Getting consumer is not supported");
         }
 
-        if (partition != 0 && partionedTopicPresent == false) {
+        if ((partition != 0) && (partionedTopicPresent == false)) {
             throw new PulsarClientException("No Partioned topic present");
         }