public class KafkaRemoteUtil extends Object
Modifier and Type | Method and Description |
---|---|
static org.apache.kafka.clients.consumer.KafkaConsumer |
getConsumer(String topic,
Properties properties) |
static Listener |
getListener(Properties props,
boolean isLocal) |
static ListenerThread |
getListenerThread(TopicsConfig topicsConfig,
boolean isLocal,
Properties configuration) |
static Properties |
getMergedConf(Properties configuration) |
static Producer |
getProducer(boolean isLocal) |
public static Listener getListener(Properties props, boolean isLocal)
public static ListenerThread getListenerThread(TopicsConfig topicsConfig, boolean isLocal, Properties configuration)
public static Producer getProducer(boolean isLocal)
public static Properties getMergedConf(Properties configuration)
public static org.apache.kafka.clients.consumer.KafkaConsumer getConsumer(String topic, Properties properties)
Copyright © 2001–2020 JBoss by Red Hat. All rights reserved.