pswamp.test_utils.offline.topic_getter

Classes

`TopicGetter`
`TopicToFile`
`TopicFromFile`

Module Contents

class pswamp.test_utils.offline.topic_getter.TopicGetter(topic, kafka_kwargs, relative_start_offset=-np.inf, empty_topic_timeout=0.2)

data = []

consumer

consumer_thread

newest_msg = None

run()

store_data(msg)

class pswamp.test_utils.offline.topic_getter.TopicToFile(*args, file_path, **kwargs)

Bases: TopicGetter

file_path

file

store_data(msg)

class pswamp.test_utils.offline.topic_getter.TopicFromFile(file_path)

file_path

data = []