Package io.smallrye.reactive.messaging.kafka.impl

Class ConfigurationCleaner

java.lang.Object

io.smallrye.reactive.messaging.kafka.impl.ConfigurationCleaner

public class ConfigurationCleaner
extends Object

Method Summary

Modifier and Type	Method	Description
static Map<String,Object>	asKafkaConfiguration(Map<String,String> conf)
static void	cleanupConsumerConfiguration(Map<String,?> conf)
static io.vertx.core.json.JsonObject	cleanupProducerConfiguration(io.vertx.core.json.JsonObject json)
static void	cleanupProducerConfiguration(Map<String,?> json)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

cleanupProducerConfiguration

public static io.vertx.core.json.JsonObject cleanupProducerConfiguration(io.vertx.core.json.JsonObject json)

cleanupProducerConfiguration

public static void cleanupProducerConfiguration(Map<String,?> json)

cleanupConsumerConfiguration

public static void cleanupConsumerConfiguration(Map<String,?> conf)

asKafkaConfiguration

public static Map<String,Object> asKafkaConfiguration(Map<String,String> conf)