#164

src/main/java/io/github/eocqrs/kafka/consumer/KfConsumer.java

@@ -22,11 +22,9 @@
 
 package io.github.eocqrs.kafka.consumer;
 
-import com.jcabi.xml.XML;
 import io.github.eocqrs.kafka.Consumer;
 import io.github.eocqrs.kafka.ConsumerSettings;
 import io.github.eocqrs.kafka.Dataized;
-import io.github.eocqrs.kafka.consumer.settings.KfConsumerSettings;
 import io.github.eocqrs.kafka.data.KfData;
 import org.apache.kafka.clients.consumer.KafkaConsumer;
 
@@ -41,7 +39,6 @@
  * @author Aliaksei Bialiauski (abialiauski.dev@gmail.com)
  * @since 0.0.0
  */
-@SuppressWarnings("removal")
 public final class KfConsumer<K, X> implements Consumer<K, X> {
 
   /**
@@ -68,15 +65,6 @@ public KfConsumer(final ConsumerSettings<K, X> settings) {
     this(settings.consumer());
   }
 
-  /**
-   * Ctor.
-   *
-   * @param settings XML settings
-   */
-  public KfConsumer(final XML settings) {
-    this(new KfConsumerSettings<>(settings));
-  }
-
   @Override
   public void subscribe(final Collection<String> topics) {
     this.origin.subscribe(topics);
@@ -116,4 +104,4 @@ public List<Dataized<X>> iterate(final String topic, final Duration timeout) {
   public void close() {
     this.origin.close();
   }
-}
+}

src/main/java/io/github/eocqrs/kafka/consumer/settings/KfConsumerParams.java

@@ -8,7 +8,7 @@
 import java.util.Collection;
 
 /**
- * Kafka params for {@link KfConsumerSettings}.
+ * Kafka params for {@link io.github.eocqrs.kafka.consumer.KfConsumer}.
  * Decorates {@link Params}.
  *
  * @author Ivan Ivanchuk (l3r8y@duck.com)

src/main/java/io/github/eocqrs/kafka/producer/KfProducer.java

@@ -26,7 +26,6 @@
 import io.github.eocqrs.kafka.Data;
 import io.github.eocqrs.kafka.Producer;
 import io.github.eocqrs.kafka.ProducerSettings;
-import io.github.eocqrs.kafka.producer.settings.KfProducerSettings;
 import org.apache.kafka.clients.producer.KafkaProducer;
 import org.apache.kafka.clients.producer.ProducerRecord;
 
@@ -64,15 +63,6 @@ public KfProducer(final ProducerSettings<K, X> settings) {
     this(settings.producer());
   }
 
-  /**
-   * Ctor.
-   *
-   * @param settings XML settings
-   */
-  public KfProducer(final XML settings) {
-    this(new KfProducerSettings<K, X>(settings).producer());
-  }
-
   @Override
   public void send(final K key, final Data<X> data) {
     this.origin.send(
@@ -89,4 +79,4 @@ public void send(final K key, final Data<X> data) {
   public void close() {
     this.origin.close();
   }
-}
+}

src/main/java/io/github/eocqrs/kafka/producer/settings/KfProducerParams.java

@@ -30,7 +30,7 @@
 import java.util.Collection;
 
 /**
- * Kafka Producer parameters.
+ * Kafka Producer parameters for {@link io.github.eocqrs.kafka.producer.KfProducer}.
  * Decorates {@link Params}.
  *
  * @author Aliaksei Bialiauski (abialiauski.dev@gmail.com)