1.0.2-beta

• Updated dev dependency version constraints to allow major version updates
• Changed _consumer_handler function signature, adding commit_each_message flag
• Moved get_consumer and get_producer into Topic as private methods
• Topic.next uses own Consumer instance that's closed down correctly
• Fixed slicing bug involving start and end slice parameters
• Made underlying Consumer and Producer instances available under Topic.consumer and Topic.producer

1.0.0

• Added locking for rocksdict operations to avoid race conditions
• Calling a handler function manually no longer requires passing a dictionary for the kwargs argument
• Added type hints to curried functions
• Using snapstream cache --stats in the snapstream command will now only show db stats
• Added example docs showing an implementation of API endpoints

1.0.0-beta

• Added locking for rocksdict operations to avoid race conditions
• Calling a handler function manually no longer requires passing a dictionary for the kwargs argument
• Added type hints to curried functions

0.0.9

• Fix cli bug that failed getting schema_path from the .snapstreamcfg config file

0.0.8

Not backwards compatible:

• Next to raising kafka message errors when passing raise_error=True, they are raised when error is fatal or non-retriable

Backwards compatible:

• Uses /etc/secrets in cli as default path for file secrets

• Uses secrets_base_path from the .snapstreamcfg file if available

• Uses schema_path from the .snapstreamcfg file -- for avro deserialization -- if available

• Shows "(catching up)" when messages read by cli tool are created before the command was executed

0.0.7

Not backwards compatible:

• All exceptions (including SystemExit) are now being caught and sent to the main thread, causing not just a thread but the whole program to crash (as it should)

• No longer raises kafka message errors by default, change back to old behavior by passing raise_error=True in get_consumer

Backwards compatible:

• AvroCodec now accepts an avro.schema.Schema instance besides an .avsc filepath string

• Fixed a bug that prevented reading offset 0 while slicing a topic, because 0 is falsy

• Added slicing, testing, and revamped index docs

0.0.6

• now calling producers poll method by default

• bumped dependencies

0.0.5

• Added topic slicing/indexing.

• Added ability for user to define produce logic by passing pusher function to Topic.

• Added CLI docs.

• Added kafka integration tests.

• Fixed bug where some log entries were not passing through the log filter.

• Fixed CLI bug where escaping '$' in config failed.

• Fixed bug where CLI would create folder if cache path didn't exist.

• Fixed bug where CLI topic value was decoded even if it was already decoded using a codec.

• Disabled setting loglevel.

0.0.4

• Added readthedocs documentation.

• Fixed keyboardinterrupt to stop the program.

• Added support for argumentless handler functions.

• Moved kafka configuration warning log filter.

• Added function to get admin client.

• Added 'auto.offset.reset': 'earliest' in examples.

• Using Cache contextmanager now returns a Cache instance.

• Added escape option for for literal values starting with $ in CLI config file.

• Using absolute cache path in CLI config file.

0.0.3

• providing cli command to read data from Topic/Cache
• replacing Cache default "with_ttl" access_type with "read_write"
• allow "yield" to be used in handler functions