root
API
Generated with
root/org.eso.ias/org.eso.ias.dasu/org.eso.ias.dasu.subscriber/KafkaSubscriber

KafkaSubscriber

org.eso.ias.dasu.subscriber.KafkaSubscriber
See theKafkaSubscriber companion class
object KafkaSubscriber

KafkaSubscriber companion object

Attributes

Companion
class
Graph
Supertypes
class Object
trait Matchable
class Any
Self type

Members list

Value members

Concrete methods

def apply(subscriberId: String, kafkaTopic: Option[String], kafkaServers: Option[String], props: Properties): KafkaSubscriber

Factory method

Factory method

Value parameters

kafkaServers

kafka servers; overridden by KafkaHelper.BROKERS_PROPNAME java property, if present

kafkaTopic

the kafka topic to send the output to; if empty uses defaults from KafkaHelper

props

additional set of properties

subscriberId

the identifier

Attributes

Generated with