TopicNames

class lsst.ts.salkafka.TopicNames(partitions: int, add_ackcmd: bool = False, commands: Sequence[str] = (), events: Sequence[str] = (), telemetry: Sequence[str] = ())

Bases: object

A collection of topic names.

Topic names must omit the command_ and logevent_ prefix. For example specify “start” instead of “command_start”, and “summaryState” instead of “logevent_summaryState”.

Parameters:

partitionsint

The desired number of Kafka partitions for these topics.

add_ackcmdbool, optional

Add ackcmd topic to the producer?

commandslist of str, optional

Commands to add to the producer, with no prefix, e.g. “enable”. Converted to a sorted list.

eventslist of str, optional

Events to add to the producer, with no prefix, e.g. “summaryState”. Converted to a sorted list.

telemetrylist of str, optional

Telemtry topics to add to the producer. Converted to a sorted list.

Attributes Summary

add_ackcmd
commands
events
telemetry

Attributes Documentation

add_ackcmd: bool = False

commands: Sequence[str] = ()

events: Sequence[str] = ()

telemetry: Sequence[str] = ()