io.smallrye.reactive.messaging.kafka.impl

Class KafkaAdminHelper

java.lang.Object

io.smallrye.reactive.messaging.kafka.impl.KafkaAdminHelper

public class KafkaAdminHelper
extends Object

Method Summary

Modifier and Type	Method and Description
static KafkaAdmin	createAdminClient(Map<String,Object> kafkaConfigurationMap, String channel, boolean incoming)

Methods inherited from class java.lang.Object

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

Method Detail

createAdminClient

public static KafkaAdmin createAdminClient(Map<String,Object> kafkaConfigurationMap,
                                           String channel,
                                           boolean incoming)