kafka_collector qoa4ml.collector.kafka_collector ¶ Classes¶ KafkaCollector ¶ Functions¶ start_collecting() ¶ Subscribe to the configured topic and dispatch each message. Previously the loop polled without subscribing and discarded every received message, so the collector silently dropped all traffic.