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 12:58:00 UTC
[incubator-eventmesh] branch master updated: Issue #1563 removed unused variable
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 633df7fd Issue #1563 removed unused variable
new 6d42e07a Merge pull request #1578 from tomekoleksy/fix_patch_1563
633df7fd is described below
commit 633df7fd8abd17643bedf3e0a349dc1b7c16dc23
Author: Tomek Oleksy <to...@allegro.pl>
AuthorDate: Fri Oct 14 14:30:48 2022 +0200
Issue #1563 removed unused variable
---
.../apache/eventmesh/connector/kafka/producer/KafkaProducerImpl.java | 4 ----
1 file changed, 4 deletions(-)
diff --git a/eventmesh-connector-plugin/eventmesh-connector-kafka/src/main/java/org/apache/eventmesh/connector/kafka/producer/KafkaProducerImpl.java b/eventmesh-connector-plugin/eventmesh-connector-kafka/src/main/java/org/apache/eventmesh/connector/kafka/producer/KafkaProducerImpl.java
index 8b7066ed..28cdcf3a 100644
--- a/eventmesh-connector-plugin/eventmesh-connector-kafka/src/main/java/org/apache/eventmesh/connector/kafka/producer/KafkaProducerImpl.java
+++ b/eventmesh-connector-plugin/eventmesh-connector-kafka/src/main/java/org/apache/eventmesh/connector/kafka/producer/KafkaProducerImpl.java
@@ -29,12 +29,9 @@ public class KafkaProducerImpl implements Producer {
private ProducerImpl producer;
- private Properties properties;
-
@Override
public synchronized void init(Properties keyValue) {
keyValue.put(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG, "localhost:9092");
- Properties properties = (Properties) keyValue.clone();
this.producer = new ProducerImpl(keyValue);
}
@@ -84,7 +81,6 @@ public class KafkaProducerImpl implements Producer {
// producer.setExtFields();
}
-
@Override
public void sendOneway(CloudEvent message) {
producer.sendOneway(message);
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@eventmesh.apache.org
For additional commands, e-mail: commits-help@eventmesh.apache.org