root
API
Generated with
root/org.eso.ias/org.eso.ias.dasu/org.eso.ias.dasu.publisher/KafkaPublisher

KafkaPublisher

org.eso.ias.dasu.publisher.KafkaPublisher
See theKafkaPublisher companion class
object KafkaPublisher

Attributes

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

Members list

Value members

Concrete methods

def apply(dasuId: String, kafkaTopic: Option[String], stringProducer: SimpleStringProducer, props: Option[Properties]): KafkaPublisher

Factory method

Factory method

Value parameters

dasuId

the identifier of the DASU

kafkaTopic

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

props

an optional set of properties

stringProducer

The string producer to push IASIOs into

Attributes

Generated with