broker/ru.sydis.broker.factory/BrokerFactory/BrokerFactory

BrokerFactory

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