You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@eventmesh.apache.org by ch...@apache.org on 2022/10/14 13:01:15 UTC
[incubator-eventmesh] branch master updated: Removed unused code in ProducerImpl.java
This is an automated email from the ASF dual-hosted git repository.
chenguangsheng pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-eventmesh.git
The following commit(s) were added to refs/heads/master by this push:
new c4c66c40 Removed unused code in ProducerImpl.java
new fdbe0818 Merge pull request #1576 from Aparna-devi-chinnu-R/issue#1555fix
c4c66c40 is described below
commit c4c66c40e58c7120ebf764b282d25e1ef02fb460
Author: Aparna-devi-chinnu-R <81...@users.noreply.github.com>
AuthorDate: Fri Oct 14 17:33:35 2022 +0530
Removed unused code in ProducerImpl.java
---
.../org/apache/eventmesh/connector/kafka/producer/ProducerImpl.java | 3 ---
1 file changed, 3 deletions(-)
diff --git a/eventmesh-connector-plugin/eventmesh-connector-kafka/src/main/java/org/apache/eventmesh/connector/kafka/producer/ProducerImpl.java b/eventmesh-connector-plugin/eventmesh-connector-kafka/src/main/java/org/apache/eventmesh/connector/kafka/producer/ProducerImpl.java
index 90efb383..2e3d17d5 100644
--- a/eventmesh-connector-plugin/eventmesh-connector-kafka/src/main/java/org/apache/eventmesh/connector/kafka/producer/ProducerImpl.java
+++ b/eventmesh-connector-plugin/eventmesh-connector-kafka/src/main/java/org/apache/eventmesh/connector/kafka/producer/ProducerImpl.java
@@ -81,9 +81,6 @@ public class ProducerImpl {
}
public void send(CloudEvent cloudEvent) {
- // ProducerRecord<Void, byte[]> msg =
- // KafkaMessageFactory.createWriter(Objects.requireNonNull(cloudEvent.getSubject()))
- // .writeBinary(cloudEvent);
try {
this.producer.send(new ProducerRecord<>(cloudEvent.getSubject(), cloudEvent));
} catch (Exception e) {
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@eventmesh.apache.org
For additional commands, e-mail: commits-help@eventmesh.apache.org