ExampleConfiguration

class kafkaaggregator.config.ExampleConfiguration(ntopics: int = 10, nfields: int = 10, frequency: float = 10.0, max_messages: int = 10, source_topic_name_prefix: str = 'example')

Bases: object

Configuration for the Kafkaaggregator example.

Attributes Summary

frequency	The frequency in Hz in which messages are produced for the example topics.
max_messages	The maximum number of messages to produce.
nfields	Number of fields for source topics used in the aggregation example.
ntopics	Number of source topics used in the aggregation example.
source_topic_name_prefix	The prefix for source topic names to use with the aggregator example.

Attributes Documentation

frequency: float = 10.0

The frequency in Hz in which messages are produced for the example topics.

max_messages: int = 10

The maximum number of messages to produce. Set max_messages to a number smaller than 1 to produce an indefinite number of messages.

nfields: int = 10

Number of fields for source topics used in the aggregation example.

ntopics: int = 10

Number of source topics used in the aggregation example.

source_topic_name_prefix: str = 'example'

The prefix for source topic names to use with the aggregator example.