Package app.ductape.sdk.brokers.utils.providers

Class KafkaService

java.lang.Object

app.ductape.sdk.brokers.utils.providers.KafkaService

All Implemented Interfaces:

BrokerTypes.IMessageBrokerService

public final class KafkaService
extends Object
implements BrokerTypes.IMessageBrokerService

Kafka provider runtime parity with TS kafka.service.ts.

Constructor Summary

Constructors

Constructor	Description
KafkaService(Map<String,Object> config)

Method Summary

Modifier and Type	Method	Description
void	connect()
void	disconnect()
void	publish(String topic, Map<String,Object> message)
void	subscribe(String topic, BrokerTypes.MessageCallback callback)

Methods inherited from class java.lang.Object

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

Constructor Details

KafkaService

public KafkaService(Map<String,Object> config)

Method Details

connect

public void connect()

Specified by:

connect in interface BrokerTypes.IMessageBrokerService

publish

public void publish(String topic,
 Map<String,Object> message)

Specified by:

publish in interface BrokerTypes.IMessageBrokerService

subscribe

public void subscribe(String topic,
 BrokerTypes.MessageCallback callback)

Specified by:

subscribe in interface BrokerTypes.IMessageBrokerService

disconnect

public void disconnect()

Specified by:

disconnect in interface BrokerTypes.IMessageBrokerService