public class KafkaListenerThread extends Object implements ListenerThread
Constructor and Description |
---|
KafkaListenerThread(Properties configuration,
TopicsConfig config,
Map<String,CompletableFuture<Object>> requestsStore) |
Modifier and Type | Method and Description |
---|---|
void |
run() |
void |
stop() |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
complete, get, get, getMergedConf
public KafkaListenerThread(Properties configuration, TopicsConfig config, Map<String,CompletableFuture<Object>> requestsStore)
public void stop()
stop
in interface ListenerThread
Copyright © 2001–2020 JBoss by Red Hat. All rights reserved.