Release History

v0.10.0 (2023-02-17)

add bluesky_kafka.consume.BasicConsumer and make it the parent of bluesky_kafka.BlueskyConsumer
add bluesky_kafka.produce.BasicProducer and make it the parent of bluesky_kafka.Publisher
sanitize str(BlueskyConsumer) output

v0.9.1 (2022-07-28)

sanitize str(Publisher) output
fix a syntax error in mongo_normalized_consumer.py

v0.9.0 (2022-04-05)

bug fix to list_topics
add TLS configuration to MongoConsumer
poll for delivery reports after every message publication

v0.8.0 (2021-12-16)

change BlueskyKafkaException base class from BaseException to Exception

v0.7.0 (2021-12-09)

added producer configuration parameter support to functions in bluesky_kafka.utils.py

v0.6.0 (2021-10-08)

added bluesky_kafka.tools.queue_thread.py

v0.5.0 (2021-08-09)

added timeout parameter to utils.get_cluster_metadata() and utils.list_topics()
put release history in reverse chronological order

v0.4.0 (2021-04-09)

added continue_polling parameter to BlueskyConsumer.start()
added utils.py
added BlueskyKafkaException
split tests into multiple files
create and clean up topics for each test
simplified produce/consume tests to run in one process
configured live logging in pytest.ini
switched from Travis CI to GitHub Workflow for continuous integration

v0.3.0 (2020-09-03)

added BlueskyConsumer
added MongoConsumer
added supervisor configuration file for mongo_normalized_consumer.py
rewrote RemoteDispatcher to use BlueskyConsumer
changed default serialization method to MessagePack