broker/ru.sydis.broker.factory/BrokerFactory

BrokerFactory

class BrokerFactory<K : Any, V : Any>(broker: String = Config.getProperty("broker.type", "kafka"), keyClass: Class<K>, valClass: Class<V>)

Constructors

Link copied to clipboard
constructor(broker: String = Config.getProperty("broker.type", "kafka"), keyClass: Class<K>, valClass: Class<V>)

Functions

Link copied to clipboard
fun getBroker(props: Map<String, Any> = mapOf()): MessageBroker<K, V>