Bug fixes

Bug fixes

• Task panics when there are frequent rebalances fixed

Bug fixes

Bug fixes

• Transactional producer does not begin the transaction after a failure fixed
• Backends DeleteAll method added
• Admin CreateTopics incorrect timeout usage fixed

Enhancements

• Global table rebuild indexes moved to stream runner(which will significantly improve index rebuild time)

V2 Path Bug Fixes

Merge pull request #3 from gmbyapa/v2-path-fix

v2 module path updates

V2 Module Path

v2.0.1

go mod updated for v2

Initial Release

V2 Stable Release

New Features

• EOS Support
• State Store support
• New DSL operators(https://github.com/gmbyapa/kstream#features)
• KTable Support

Pre release

This is a pre release

Enhancements

Features

• Pebble support added

Bug Fixes

Bug fixes

• StateStore Set() null value should be tombstoned in cache
• StateStore Get() should check the record in cache before reading

Enhancements

• More test coverage added for State Stores
• StateStore benchmak added

Bug Fixes and Enhancements

Fixed

• Mock backend changed to badger
• Memory backend benchmark setup and cleanup added

Features

• BadgerDB support added
• Kstream now uses badger(in-memory) as default backend builder
• StateStores PrefixedIterator support added
• stores.ReadOnlyStore PrefixedIterator support added
• QueryableStoreWrapper PrefixedIterator support added

Breaking Changes ⚠️

• stores.Irerator() SeekToLast and Prev methods removed
• Backend->RangeIterator renamed to PrefixedIterator

Bug Fixes

v2.0.0-beta-3

producer metadata timeout fixed