[incubator-eventmesh] branch master updated: fix issue 1562 - remove unused variables

[ch...@apache.org]

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 3305aa6e fix issue 1562 - remove unused variables
     new ffbdc3f9 Merge pull request #1569 from lukasz-kolasa/fix_issue_1562
3305aa6e is described below

commit 3305aa6e9bf13d8d672a4efddd1df3e9b223f0a2
Author: Lukasz Kolasa <lu...@allegro.pl>
AuthorDate: Fri Oct 14 12:55:52 2022 +0200

    fix issue 1562 - remove unused variables
---
 .../eventmesh/connector/kafka/consumer/KafkaConsumerImpl.java      | 7 -------
 1 file changed, 7 deletions(-)

diff --git a/eventmesh-connector-plugin/eventmesh-connector-kafka/src/main/java/org/apache/eventmesh/connector/kafka/consumer/KafkaConsumerImpl.java b/eventmesh-connector-plugin/eventmesh-connector-kafka/src/main/java/org/apache/eventmesh/connector/kafka/consumer/KafkaConsumerImpl.java
index e03a2d97..8743ef33 100644
--- a/eventmesh-connector-plugin/eventmesh-connector-kafka/src/main/java/org/apache/eventmesh/connector/kafka/consumer/KafkaConsumerImpl.java
+++ b/eventmesh-connector-plugin/eventmesh-connector-kafka/src/main/java/org/apache/eventmesh/connector/kafka/consumer/KafkaConsumerImpl.java
@@ -22,25 +22,18 @@ import org.apache.eventmesh.api.EventListener;
 import org.apache.eventmesh.api.consumer.Consumer;
 
 import org.apache.kafka.clients.consumer.ConsumerConfig;
-import org.apache.kafka.common.serialization.StringDeserializer;
 
 import java.util.List;
 import java.util.Properties;
 
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-
 import io.cloudevents.CloudEvent;
 
 public class KafkaConsumerImpl implements Consumer {
-    public Logger messageLogger = LoggerFactory.getLogger("message");
-
     private ConsumerImpl consumer;
 
     @Override
     public synchronized void init(Properties props) throws Exception {
         String consumerGroup = props.getProperty("consumerGroup");
-        String bootstrapServers = props.getProperty("bootstrapServers");
         // Other config props
         props.put(ConsumerConfig.BOOTSTRAP_SERVERS_CONFIG, "localhost:9092");
 


---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@eventmesh.apache.org
For additional commands, e-mail: commits-help@eventmesh.apache.org