org.myrobotlab.service

Class KafkaConnector

java.lang.Object

org.myrobotlab.framework.Service

org.myrobotlab.service.KafkaConnector

All Implemented Interfaces:

Serializable, Runnable, Attachable, Broadcaster, Invoker, LoggingSink, MessageSender, MessageSubscriber, NameProvider, NameTypeProvider, ServiceInterface, ServiceQueue, ServiceStatus, StatePublisher, StateSaver, StatusPublisher, TypeProvider, QueueReporter

public class KafkaConnector
extends Service

A kafka connector that can subscribe to a string/string kafka stopic and publish records as they arrive. TODO: this isn't very configurable yet.. and doesn't really support much. it's really here for a reference and we can expand upon it if anyone cares to use it.

Author:

kwatters

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
String	bootstrapServers
String	groupId
String	keyDeserializer
String	valueDeserializer

Fields inherited from class org.myrobotlab.framework.Service

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 Summary

Constructors

Constructor and Description
KafkaConnector(String name, String id)

Method Summary

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)

Methods inherited from class org.myrobotlab.framework.Service

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

Methods inherited from class java.lang.Object

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

Field Detail

bootstrapServers

public String bootstrapServers

groupId

public String groupId

keyDeserializer

public String keyDeserializer

valueDeserializer

public String valueDeserializer

Constructor Detail

KafkaConnector

public KafkaConnector(String name,
                      String id)

Method Detail

connect

public void connect()

subscribeToTopic

public void subscribeToTopic(String topic)

publishRecord

public org.apache.kafka.clients.consumer.ConsumerRecord<String,String> publishRecord(org.apache.kafka.clients.consumer.ConsumerRecord<String,String> record)

main

public static void main(String[] args)