tag:github.com,2008:https://github.com/YiuRULE/faust/releasesTags from faust2022-02-25T17:14:04Ztag:github.com,2008:Repository/483695778/v0.8.42022-02-25T17:14:04Zv0.8.4: flushing producer before commit (#273)<p>flushing producer before commit (<a class="issue-link js-issue-link" href="https://github.com/faust-streaming/faust/pull/273">faust-streaming#273</a>)</p>
<p>* flushing producer before commit</p>
<p>* flushing producer before commit</p>
<p>* flushing producer before commit</p>
<p>* flushing producer before commit</p>
<p>* flushing producer before commit</p>patkivikramtag:github.com,2008:Repository/483695778/v0.8.22022-02-04T13:39:21Zv0.8.2: fix errors in seek when flow is not active (#264)<p>fix errors in seek when flow is not active (<a class="issue-link js-issue-link" href="https://github.com/faust-streaming/faust/pull/264">faust-streaming#264</a>)</p>
<p>* fix errors in seek when flow is not active</p>
<p>* fix errors in seek when flow is not active</p>
<p>* Revert "fix errors in seek when flow is not active"</p>
<p>This reverts commit <a class="commit-link" href="https://github.com/YiuRULE/faust/commit/c3fadfb5f00f432b511174076f134f54092e8e4b"><tt>c3fadfb</tt></a>.</p>patkivikramtag:github.com,2008:Repository/483695778/v0.8.12022-01-19T20:53:43Zv0.8.1: Support waiting for fetcher to finish (#263)<p>Support waiting for fetcher to finish (<a class="issue-link js-issue-link" href="https://github.com/faust-streaming/faust/pull/263">faust-streaming#263</a>)</p>
<p>Co-authored-by: Eric Kerstens <ekerstens@expediagroup.com></p>ekerstenstag:github.com,2008:Repository/483695778/v0.8.02022-01-11T20:09:00Zv0.8.0: Revert cancel getmany and add extra seek (#256)<p>Revert cancel getmany and add extra seek (<a class="issue-link js-issue-link" href="https://github.com/faust-streaming/faust/pull/256">faust-streaming#256</a>)</p>
<p>* Revert cancel getmany and add extra seek</p>
<p>* Revert test</p>
<p>* Modifications for tests</p>
<p>Co-authored-by: Eric Kerstens <ekerstens@expediagroup.com></p>ekerstenstag:github.com,2008:Repository/483695778/v0.7.92022-01-07T17:21:26Zv0.7.9: Stop fetching when flow stops (#253)<p>Stop fetching when flow stops (<a class="issue-link js-issue-link" href="https://github.com/faust-streaming/faust/pull/253">faust-streaming#253</a>)</p>
<p>* Stop fetching when flow stops</p>
<p>* Stop fetching when flow stops</p>
<p>* Change order to keep interface the same and fix test cases</p>
<p>* Fix test case</p>
<p>* try/finally for not_waiting_next_records</p>
<p>Co-authored-by: Eric Kerstens <ekerstens@expediagroup.com></p>ekerstenstag:github.com,2008:Repository/483695778/v0.7.82021-12-18T13:26:31Zv0.7.8patkivikramtag:github.com,2008:Repository/483695778/v0.7.72021-12-17T20:10:07Zv0.7.7: Take with timestamp (#242)<p>Take with timestamp (<a class="issue-link js-issue-link" href="https://github.com/faust-streaming/faust/pull/242">faust-streaming#242</a>)</p>
<p>* add full_take</p>
<p>* remove processor remove</p>
<p>* try to add kafka_timestamp</p>
<p>* tweaks</p>
<p>* add</p>
<p>* add extra param</p>
<p>* add offset</p>
<p>* remove offset in this pr</p>
<p>* fix formatting</p>
<p>* add functional tests</p>
<p>* add another unit test and edge case handling</p>
<p>* change buffer type...</p>
<p>Co-authored-by: Vikram Patki <54442035+patkivikram@users.noreply.github.com></p>nicor88tag:github.com,2008:Repository/483695778/v0.7.62021-12-15T15:18:12Zv0.7.6: Remove wait_first and extra log (#240)<p>Remove wait_first and extra log (<a class="issue-link js-issue-link" href="https://github.com/faust-streaming/faust/pull/240">faust-streaming#240</a>)</p>
<p>Co-authored-by: Eric Kerstens <ekerstens@expediagroup.com></p>ekerstenstag:github.com,2008:Repository/483695778/v0.7.52021-12-14T22:48:23Zv0.7.5: set active_tps in place (#239)<p>set active_tps in place (<a class="issue-link js-issue-link" href="https://github.com/faust-streaming/faust/pull/239">faust-streaming#239</a>)</p>
<p>* set active_tps in place</p>
<p>* Cancel getmany during rebalance</p>
<p>* Fix nonetype error</p>
<p>* Check for nonetype</p>
<p>* Fix wait_results coro check</p>
<p>* change == to is</p>
<p>Co-authored-by: Eric Kerstens <ekerstens@expediagroup.com></p>ekerstenstag:github.com,2008:Repository/483695778/v0.7.42021-12-13T20:35:38Zv0.7.4: fix race condition when buffers are full (#237)<p>fix race condition when buffers are full (<a class="issue-link js-issue-link" href="https://github.com/faust-streaming/faust/pull/237">faust-streaming#237</a>)</p>
<p>* fix race condition when buffers are full</p>
<p>* fix race condition when buffers are full</p>
<p>* Fix error messages in faust app <a class="issue-link js-issue-link" href="https://github.com/faust-streaming/faust/issues/166">faust-streaming#166</a></p>patkivikram