[misc] Improve output performance by changing Producer to use sendAsync (#25)

Andyandpandy · web-flow · commit d391f5b6235d · 2023-03-15T10:25:00.000+01:00
diff --git a/src/main/java/org/apache/pulsar/logstash/outputs/Pulsar.java b/src/main/java/org/apache/pulsar/logstash/outputs/Pulsar.java
@@ -224,7 +224,7 @@ public void output(final Collection<Event> events) {
                 logger.debug("topic is {}, message is {}", eventTopic, s);
                 getProducer(eventTopic).newMessage()
                         .value(s.getBytes())
-                        .send();
+                        .sendAsync();
             } catch (Exception e) {
                 logger.error("fail to send message", e);
             }

Original file line number	Diff line number	Diff line change
`@@ -224,7 +224,7 @@ public void output(final Collection<Event> events) {`
`224`	`224`	`logger.debug("topic is {}, message is {}", eventTopic, s);`
`225`	`225`	`getProducer(eventTopic).newMessage()`
`226`	`226`	`.value(s.getBytes())`
`227`		`- .send();`
	`227`	`+ .sendAsync();`
`228`	`228`	`} catch (Exception e) {`
`229`	`229`	`logger.error("fail to send message", e);`
`230`	`230`	`}`