public class KafkaConnector extends Service
Modifier and Type | Field and Description |
---|---|
String |
bootstrapServers |
String |
groupId |
String |
keyDeserializer |
String |
valueDeserializer |
authProvider, defaultLocalization, dnaPool, fs, id, inbox, interfaceSet, isVirtual, lastError, lastErrorTs, lastStatus, lastStatusTs, locale, localization, log, methodSet, outbox, ps, ready, serviceClass, serviceType, serviceVersion, simpleName, statusBroadcastLimitMs, thisThread
Constructor and Description |
---|
KafkaConnector(String name,
String id) |
Modifier and Type | Method and Description |
---|---|
void |
connect() |
static void |
main(String[] args) |
org.apache.kafka.clients.consumer.ConsumerRecord<String,String> |
publishRecord(org.apache.kafka.clients.consumer.ConsumerRecord<String,String> record) |
void |
subscribeToTopic(String topic) |
addListener, addListener, addListener, addListener, addTask, addTask, addTask, addTaskOneShot, attach, attach, broadcast, broadcast, broadcastState, broadcastStatus, buildDna, buildDna, buildDnaKeys, buildDnaNames, clearLastError, close, containsTask, copyResource, copyShallowFrom, createPeer, createPeer, createRootReserved, detach, detach, detach, echoHeartbeat, error, error, error, export, export, exportAll, exportAll, getAttached, getCountry, getDataDir, getDataDir, getDataInstanceDir, getDeclaredMethodNames, getDeclaredMethods, getDescription, getDisplayLanguage, getDna, getDnaString, getFile, getFullName, getHomeDir, getHostName, getId, getInbox, getInstanceId, getIntanceName, getInterfaceSet, getLanguage, getLastError, getLocale, getLocaleTag, getMessageSet, getMetaData, getMethodMap, getMethodNames, getMethods, getMethodToolTip, getMsg, getName, getNotifyList, getNotifyListKeySet, getOutbox, getPeer, getPeerKey, getPeerName, getResource, getResource, getResource, getResourceAsString, getResourceAsString, getResourceAsString, getResourceDir, getResourceDir, getResourceDir, getResourceDir, getResourceDirList, getResourceDirList, getResourceImage, getResourceRoot, getRootDataDir, getServiceIcon, getServiceIcon, getServiceIcon, getServiceScript, getServiceScript, getServiceScript, getSimpleName, getSwagger, getTasks, getThisThread, getType, hasError, hasInternet, hasPeers, hasSubscribed, help, in, info, info, invoke, invoke, invoke, invokeOn, invokeOn, invokePeer, invokePeer, isAttached, isAttached, isDev, isHeadless, isLocal, isReady, isRunning, isRuntime, isVirtual, load, load, loadAndStart, loadFromJson, loadFromJson, loadLocalizations, localize, localize, logTimeEnable, mergeDna, mergeDna, mergePeerDna, movePeerDna, out, out, preProcessHook, preRoutingHook, preShutdown, publishError, publishQueueStats, publishState, publishStats, publishStatus, purgeTask, purgeTasks, releasePeer, releasePeers, releaseService, removeAllListeners, removeListener, removeListener, requiresSecurity, reserve, reserve, reserveRoot, reserveRoot, reserveRootAs, run, save, save, save, send, send, send, sendBlocking, sendBlocking, sendBlocking, sendBlocking, sendPeer, sendToPeer, sendToPeer, setId, setInstanceId, setLocale, setName, setOrder, setPeer, setReady, setSecurityProvider, setState, setThisThread, setVirtual, sleep, sleep, stackToString, startPeer, startPeer, startPeers, startService, stopService, subscribe, subscribe, subscribe, subscribeTo, subscribeToRuntime, toString, unsubscribe, unsubscribe, unsubscribe, unsubscribeTo, unsubscribeToRuntime, updateStats, warn, warn
public String bootstrapServers
public String groupId
public String keyDeserializer
public String valueDeserializer
public void connect()
public void subscribeToTopic(String topic)
public org.apache.kafka.clients.consumer.ConsumerRecord<String,String> publishRecord(org.apache.kafka.clients.consumer.ConsumerRecord<String,String> record)
public static void main(String[] args)
Copyright © 2020 myrobotlab. All rights reserved.