Skip to content

Tags: popadi/faust

Tags

v0.8.5

Toggle v0.8.5's commit message

Verified

This commit was created on GitHub.com and signed with GitHub’s verified signature. The key has expired.
Faust commits the wrong offset in case of a gap in acks faust-streami…

…ng#312 (faust-streaming#313)

* Faust commits the wrong offset in case of a gap in acks faust-streaming#312

Faust commits the wrong offset in case of a gap in acks faust-streaming#312

Co-Authored-By: ekerstens <49325583+ekerstens@users.noreply.github.com>

* kljlk

jhkjhj

* Revert "kljlk"

This reverts commit 8b487fc.

* update fix faust-streaming#313

Co-Authored-By: ekerstens <49325583+ekerstens@users.noreply.github.com>

* update test case

Co-Authored-By: ekerstens <49325583+ekerstens@users.noreply.github.com>
Co-Authored-By: Leo <47164895+LeohuangLeo@users.noreply.github.com>

Co-authored-by: Leo Huang <s3563602123@gmail.com>
Co-authored-by: ekerstens <49325583+ekerstens@users.noreply.github.com>
Co-authored-by: Leo <47164895+LeohuangLeo@users.noreply.github.com>

v0.8.4

Toggle v0.8.4's commit message

Verified

This commit was created on GitHub.com and signed with GitHub’s verified signature. The key has expired.
flushing producer before commit (faust-streaming#273)

* flushing producer before commit

* flushing producer before commit

* flushing producer before commit

* flushing producer before commit

* flushing producer before commit

v0.8.2

Toggle v0.8.2's commit message

Verified

This commit was created on GitHub.com and signed with GitHub’s verified signature. The key has expired.
fix errors in seek when flow is not active (faust-streaming#264)

* fix errors in seek when flow is not active

* fix errors in seek when flow is not active

* Revert "fix errors in seek when flow is not active"

This reverts commit c3fadfb.

v0.8.1

Toggle v0.8.1's commit message

Verified

This commit was created on GitHub.com and signed with GitHub’s verified signature. The key has expired.
Support waiting for fetcher to finish (faust-streaming#263)

Co-authored-by: Eric Kerstens <ekerstens@expediagroup.com>

v0.8.0

Toggle v0.8.0's commit message

Verified

This commit was created on GitHub.com and signed with GitHub’s verified signature. The key has expired.
Revert cancel getmany and add extra seek (faust-streaming#256)

* Revert cancel getmany and add extra seek

* Revert test

* Modifications for tests

Co-authored-by: Eric Kerstens <ekerstens@expediagroup.com>

v0.7.9

Toggle v0.7.9's commit message

Verified

This commit was created on GitHub.com and signed with GitHub’s verified signature. The key has expired.
Stop fetching when flow stops (faust-streaming#253)

* Stop fetching when flow stops

* Stop fetching when flow stops

* Change order to keep interface the same and fix test cases

* Fix test case

* try/finally for not_waiting_next_records

Co-authored-by: Eric Kerstens <ekerstens@expediagroup.com>

v0.7.8

Toggle v0.7.8's commit message
updating master version

v0.7.7

Toggle v0.7.7's commit message

Verified

This commit was created on GitHub.com and signed with GitHub’s verified signature. The key has expired.
Take with timestamp (faust-streaming#242)

* add full_take

* remove processor remove

* try to add kafka_timestamp

* tweaks

* add

* add extra param

* add offset

* remove offset in this pr

* fix formatting

* add functional tests

* add another unit test and edge case handling

* change buffer type...

Co-authored-by: Vikram Patki <54442035+patkivikram@users.noreply.github.com>

v0.7.6

Toggle v0.7.6's commit message

Verified

This commit was created on GitHub.com and signed with GitHub’s verified signature. The key has expired.
Remove wait_first and extra log (faust-streaming#240)

Co-authored-by: Eric Kerstens <ekerstens@expediagroup.com>

v0.7.5

Toggle v0.7.5's commit message

Verified

This commit was created on GitHub.com and signed with GitHub’s verified signature. The key has expired.
set active_tps in place (faust-streaming#239)

* set active_tps in place

* Cancel getmany during rebalance

* Fix nonetype error

* Check for nonetype

* Fix wait_results coro check

* change == to is

Co-authored-by: Eric Kerstens <ekerstens@expediagroup.com>