0.7.1

0.7.1 (2022-12-06)

Fix

• call deserializer regardless consumer_record value (#83)

[master 112d1ce] bump: version 0.7.0 → 0.7.1
2 files changed, 8 insertions(+), 2 deletions(-)

0.7.0

0.7.0 (2022-11-28)

Feat

• adds ability for stream to be initiated with initial offsets

[master 5e3613c] bump: version 0.6.15 → 0.7.0
2 files changed, 8 insertions(+), 2 deletions(-)

0.6.15

0.6.15 (2022-11-23)

Perf

• test_utils: replace sleep with async queue join when stopping test stream (#78)

[master 79c5195] bump: version 0.6.14 → 0.6.15
2 files changed, 8 insertions(+), 2 deletions(-)

0.6.14

0.6.14 (2022-11-17)

Fix

• add remove-stream function to stream_engine

[master c15f31f] bump: version 0.6.13 → 0.6.14
2 files changed, 8 insertions(+), 2 deletions(-)

0.6.13

0.6.13 (2022-11-11)

Fix

• stream: recreate consumer when a stream instance is restarted (#77)

[master b4dd516] bump: version 0.6.12 → 0.6.13
2 files changed, 8 insertions(+), 2 deletions(-)

0.6.12

0.6.12 (2022-11-08)

Fix

• teststreamclient: check if consumer is none before creating one

[master bb96361] bump: version 0.6.11 → 0.6.12
2 files changed, 8 insertions(+), 2 deletions(-)

0.6.11

0.6.11 (2022-11-02)

Fix

• TestStreamClient: remove unused/unclosed mock producer (#74)

[master a6e9190] bump: version 0.6.10 → 0.6.11
2 files changed, 8 insertions(+), 2 deletions(-)

0.6.10

0.6.10 (2022-10-13)

Fix

• test_clients.py: adds end_offsets to consumer test client

[master 629f35d] bump: version 0.6.9 → 0.6.10
2 files changed, 8 insertions(+), 2 deletions(-)

0.6.9

0.6.9 (2022-10-12)

Fix

• add partitions_for_topic method to consumer test client (#70)

[master faed11f] bump: version 0.6.8 → 0.6.9
2 files changed, 8 insertions(+), 2 deletions(-)

0.6.8

0.6.8 (2022-10-12)

Fix

• clean up topic events after leaving the async context (#68)

[master f8b4639] bump: version 0.6.7 → 0.6.8
2 files changed, 8 insertions(+), 2 deletions(-)