fix todo, remove unused import

Signed-off-by: Johannes Schneider <johannes.schneider@bosch.io>
eclipse-ditto · Jun 22, 2021 · e2dd6b7 · e2dd6b7
1 parent 08c2a91
commit e2dd6b7
Showing 1 changed file with 1 addition and 2 deletions.
diff --git a/.../main/java/org/eclipse/ditto/connectivity/service/messaging/kafka/KafkaConsumerActor.java b/.../main/java/org/eclipse/ditto/connectivity/service/messaging/kafka/KafkaConsumerActor.java
@@ -32,7 +32,6 @@
 import org.eclipse.ditto.connectivity.model.EnforcementFilterFactory;
 import org.eclipse.ditto.connectivity.model.ResourceStatus;
 import org.eclipse.ditto.connectivity.model.Source;
-import org.eclipse.ditto.connectivity.service.config.KafkaConfig;
 import org.eclipse.ditto.connectivity.service.config.KafkaConsumerConfig;
 import org.eclipse.ditto.connectivity.service.messaging.BaseConsumerActor;
 import org.eclipse.ditto.connectivity.service.messaging.internal.RetrieveAddressStatus;
@@ -51,7 +50,7 @@
 import scala.util.Either;
 
 /**
- * TODO
+ * Actor which streams messages from Kafka.
  */
 final class KafkaConsumerActor extends BaseConsumerActor {