org.eso.ias.dasu.publisher.KafkaPublisher
See theKafkaPublisher companion object
Publishes the output to Kafka queues by delegating to SimpleStringProducer.
The id of the IASIO to published is used as key.
Value parameters
-
dasuId
-
te identifier of the DASU
-
kafkaProducer
-
the kafka producer
-
props
-
additional set of properties
Attributes
-
Companion
-
object
-
Graph
-
-
Supertypes
-
class Object
trait Matchable
class Any
Members list
Release all the acquired kafka resources.
Release all the acquired kafka resources.
Attributes
-
Definition Classes
-
Initialize the Kafka subscriber.
Initialize the Kafka subscriber.
Attributes
-
Returns
-
Success or Failure if the initialization went well or encountered a problem
-
Definition Classes
-
Publish the output to the kafka topic.
Publish the output to the kafka topic.
Value parameters
-
iasio
-
the not null IASIO to publish
Attributes
-
Returns
-
a try to let the caller aware of errors publishing
-
Definition Classes
-