UnexpectedNumberOfTopicsError

exception kafkaaggregator.example.UnexpectedNumberOfTopicsError

Bases: RuntimeError

Raised when the number of source topics is unnexpected.

The number of source topics in Kafka must match the number of topics initialized by the example.