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>

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

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.

Support waiting for fetcher to finish (faust-streaming#263)

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

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>

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>

updating master version

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>

Remove wait_first and extra log (faust-streaming#240)

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

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>