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>

fix race condition when buffers are full (faust-streaming#237)

* fix race condition when buffers are full

* fix race condition when buffers are full

* Fix error messages in faust app faust-streaming#166