faust-streaming/faust issues and pull requests

#648 - Update python-package.yml to formally support Python 3.13

Pull Request - State: closed - Opened by wbarnha 7 days ago - 1 comment

#647 - Bump codecov/codecov-action from 3 to 5

Pull Request - State: open - Opened by dependabot[bot] 12 days ago
Labels: dependencies, github_actions

#646 - DeprecationWarning: pkg_resources is deprecated as an API

Issue - State: open - Opened by Dimasbka 2 months ago - 1 comment

#645 - Add on_clear handlers to (Global)Table and ChangeloggedSet

Pull Request - State: closed - Opened by egao1980 2 months ago

#644 - Bump actions/download-artifact from 3 to 4.1.7 in /.github/workflows

Pull Request - State: closed - Opened by dependabot[bot] 3 months ago - 4 comments
Labels: dependencies, github_actions

#643 - App ignores topic that exists on Kafka

Issue - State: closed - Opened by mrabey 3 months ago - 1 comment

#642 - Pytest hangs with scope='session' async fixture

Issue - State: open - Opened by snb2013 3 months ago

#641 - Remove loop argument from `aiokafka` driver

Pull Request - State: closed - Opened by didimelli 4 months ago - 2 comments

#640 - Consumers slowly die over time in the new Faust version 0.11.2

Issue - State: open - Opened by MedAzizTousli 4 months ago - 1 comment
Labels: duplicate

#639 - Rename to topic_errors for newer versions of aiokafka and bump minimum version to v0.10.0

Pull Request - State: closed - Opened by wbarnha 4 months ago - 1 comment

#638 - setuptools removed setuptools.command.test and faust-streaming is failing pip install

Issue - State: open - Opened by daher928 4 months ago - 3 comments

#637 - How Can I get stream one value in HTTP Request?

Issue - State: open - Opened by mekhicode 4 months ago

#636 - Add override_logging argument to Worker (#634)

Pull Request - State: closed - Opened by lpogo 4 months ago - 18 comments

#635 - Replace aredis with redis-py

Pull Request - State: closed - Opened by wbarnha 4 months ago - 4 comments

#634 - Worker logging doesn't work

Issue - State: open - Opened by lpogo 4 months ago

#633 - aiokafka create topic error > 0.10.0

Issue - State: closed - Opened by MarkCWirt 5 months ago - 8 comments

#632 - GlobalTable doesnt respect schema

Issue - State: open - Opened by kokorins 5 months ago

#631 - fix: aiokafka `0.11.0` error when creating topics

Pull Request - State: closed - Opened by somnam 5 months ago - 1 comment

#630 - Error when creating a topic using aiokafka 0.11.0

Issue - State: closed - Opened by hgalytoby 5 months ago - 5 comments

#629 - Certain topic partitions are not sending fetch requests since initial start

Issue - State: open - Opened by Syntaf 5 months ago

#628 - Testing: timers

Issue - State: open - Opened by giulioindev 6 months ago

#627 - Remove aredis

Issue - State: open - Opened by dakotahorstman 7 months ago

#626 - StreamT has no filter abstract method

Issue - State: open - Opened by giulioindev 7 months ago

#625 - How to check liveness of agent?

Issue - State: open - Opened by caspereijkens 7 months ago - 6 comments

#624 - Question: Throttle Reconnect Attempts when kafka is unavailable

Issue - State: open - Opened by jaredvacanti 7 months ago - 1 comment

#623 - normal logging mode

Issue - State: open - Opened by lubomirmatus 8 months ago

#622 - update faust

Pull Request - State: closed - Opened by owen-zora 8 months ago - 1 comment

#621 - Skip some PyPy tests and revert breaking poll_at timestamp change

Pull Request - State: closed - Opened by wbarnha 8 months ago - 1 comment

#620 - 0.10.22 is broken

Issue - State: closed - Opened by Badgerr 8 months ago - 4 comments

#619 - Pin pytest<8 to fix Python 3.11 tests

Pull Request - State: closed - Opened by wbarnha 8 months ago - 1 comment

#618 - Fix imports from updates in mode-streaming~=0.4.0

Pull Request - State: closed - Opened by wbarnha 8 months ago

#617 - ModuleNotFoundError: No module named 'mode.utils.typing'

Issue - State: closed - Opened by klajdicaushi 8 months ago - 4 comments

#616 - Add a method to include the whole message when using the take method

Issue - State: closed - Opened by fonty422 8 months ago - 1 comment

#614 - Bump actions/download-artifact from 3 to 4

Pull Request - State: closed - Opened by dependabot[bot] 8 months ago - 4 comments
Labels: dependencies, github_actions

#613 - Fix prometheus registry

Pull Request - State: closed - Opened by krzysieksulejczak 9 months ago - 1 comment

#612 - fix: serialize (named)tuple when using orjson

Pull Request - State: closed - Opened by zevisert 9 months ago - 1 comment

#611 - Does Faust Streaming Consumer retry the offset commit if it fails?

Issue - State: open - Opened by arcanjo45 9 months ago - 1 comment

#610 - Fix disabled aiokafka unit tests

Pull Request - State: closed - Opened by wbarnha 9 months ago - 1 comment
Labels: bug, help wanted

#609 - Run black and update setup.cfg for flake8 to ignore E701 and E704

Pull Request - State: closed - Opened by Tim-Thomas 9 months ago - 2 comments

#608 - bugfix: Fix cython _on_stream_event_in call to match python impl

Pull Request - State: closed - Opened by Tim-Thomas 9 months ago - 3 comments
Labels: bug

#607 - Logic around sensor _on_stream_event_in differs between cython and python implementations

Issue - State: closed - Opened by Tim-Thomas 9 months ago

#606 - Wrong offset commit in case of gaps

Issue - State: open - Opened by vitalbbyy 10 months ago
Labels: bug

#605 - Events getting skipped

Issue - State: open - Opened by VatsalLalcheta 10 months ago - 1 comment

#604 - Bump codecov/codecov-action from 3 to 4

Pull Request - State: closed - Opened by dependabot[bot] 10 months ago - 1 comment
Labels: dependencies, github_actions

#603 - Closing connection

Issue - State: open - Opened by Abraham-liuhai 10 months ago

#602 - Rebalancing problem with Faust Streaming

Issue - State: open - Opened by arcanjo45 11 months ago

#601 - `SetTable`s are missing `on_clear`

Issue - State: closed - Opened by cristianmatache 11 months ago - 1 comment

#600 - enable kafka static-partition-assignment (KIP-345)

Pull Request - State: closed - Opened by Mopsgeschwindigkeit 11 months ago - 1 comment

#599 - Bump actions/upload-artifact from 3 to 4

Pull Request - State: closed - Opened by dependabot[bot] 11 months ago - 3 comments
Labels: dependencies, github_actions

#598 - Use `loop.create_task()` for agent tasks

Pull Request - State: closed - Opened by samtx 11 months ago - 2 comments

#597 - Cannot recover when any changelog topic partition becomes empty (as a result of some retention policy)

Issue - State: open - Opened by cristianmatache 11 months ago

#596 - A race condition in recovery causes unrecoverable gaps in acked offsets and consequently blocks committing

Issue - State: open - Opened by cristianmatache 11 months ago
Labels: bug

#595 - Add example for medium/large projects in FastAPI

Pull Request - State: closed - Opened by hgalytoby 11 months ago - 3 comments

#594 - Rebalancing problem with Faust Streaming consumer

Issue - State: open - Opened by arcanjo45 11 months ago

#593 - Bump actions/upload-pages-artifact from 2 to 3

Pull Request - State: closed - Opened by dependabot[bot] 11 months ago - 1 comment
Labels: dependencies, github_actions

#592 - Bump actions/deploy-pages from 3 to 4

Pull Request - State: closed - Opened by dependabot[bot] 11 months ago - 1 comment
Labels: dependencies, github_actions