ComponentProducer

class lsst.ts.salkafka.ComponentProducer(domain, name, kafka_info)

Bases: object

Produce Kafka messages from DDS samples for one SAL component.

Parameters:

domain : lsst.ts.salobj.Domain

DDS domain participant and quality of service information.

name : str

Name of SAL component, e.g. “ATDome”.

kafka_info : KafkaInfo

Information and clients for using Kafka.

Methods Summary

close()	Shut down and clean up resources.
start()	Start the contained lsst.ts.salobj.SalInfo and Kafka producers.

Methods Documentation

close()

Shut down and clean up resources.

Close the contained lsst.ts.salobj.SalInfo, but not the domain, because that is almost certainly used by other objects.

start()

Start the contained lsst.ts.salobj.SalInfo and Kafka producers.