pswamp.test_utils.csv_playback.kafka_streamer

Classes

PMUDataStreamerKafka

Module Contents

class pswamp.test_utils.csv_playback.kafka_streamer.PMUDataStreamerKafka(pmu_data_folder, publisher_kwargs, case_name_hint='', pdc_id=1, publish_frequency=50, speed=1, n_samples=None, t_end=None, skip_seconds_in_beginning=0, *args, **kwargs)

Bases: pswamp.test_utils.csv_playback.pmu_streamer.PMUDataStreamer

init_publisher(topic, **kafka_kwargs)

publish(data_frame)