faust-streaming faust issues

faust-streaming / faust

Python Stream Processing. A Faust fork

https://faust-streaming.github.io/faust/

Other

1.62k stars 180 forks source link

issues

Newest

Newest Most commented Recently updated Oldest Least commented Least recently updated

DeprecationWarning: pkg_resources is deprecated as an API

#646 Dimasbka opened 1 week ago
0
Add on_clear handlers to (Global)Table and ChangeloggedSet

#645 egao1980 opened 1 week ago
0
Bump actions/download-artifact from 3 to 4.1.7 in /.github/workflows

#644 dependabot[bot] closed 4 weeks ago
4
App ignores topic that exists on Kafka

#643 mrabey closed 1 month ago
1
Pytest hangs with scope='session' async fixture

#642 snb2013 opened 1 month ago
0
Remove loop argument from `aiokafka` driver

#641 didimelli closed 1 month ago
2
Consumers slowly die over time in the new Faust version 0.11.2

#640 MedAzizTousli opened 1 month ago
1
Rename to topic_errors for newer versions of aiokafka and bump minimum version to v0.10.0

#639 wbarnha closed 1 month ago
1
setuptools removed setuptools.command.test and faust-streaming is failing pip install

#638 daher928 opened 2 months ago
3
How Can I get stream one value in HTTP Request?

#637 mekhicode opened 2 months ago
0
Add override_logging argument to Worker (#634)

#636 lpogo closed 2 months ago
18
Replace aredis with redis-py

#635 wbarnha opened 2 months ago
3
Worker logging doesn't work

#634 lpogo opened 2 months ago
0
aiokafka create topic error > 0.10.0

#633 MarkCWirt closed 1 month ago
8
GlobalTable doesnt respect schema

#632 kokorins opened 2 months ago
0
fix: aiokafka `0.11.0` error when creating topics

#631 somnam closed 2 months ago
1
Error when creating a topic using aiokafka 0.11.0

#630 hgalytoby closed 2 months ago
5
Certain topic partitions are not sending fetch requests since initial start

#629 Syntaf opened 3 months ago
0
Testing: timers

#628 giulioindev opened 3 months ago
0
Remove aredis

#627 dakotahorstman opened 4 months ago
0
StreamT has no filter abstract method

#626 giulioindev opened 4 months ago
0
How to check liveness of agent?

#625 caspereijkens opened 5 months ago
6
Question: Throttle Reconnect Attempts when kafka is unavailable

#624 jaredvacanti opened 5 months ago
1
normal logging mode

#623 lubomirmatus opened 5 months ago
0
update faust

#622 owen-zora closed 6 months ago
1
Skip some PyPy tests and revert breaking poll_at timestamp change

#621 wbarnha closed 6 months ago
1
0.10.22 is broken

#620 Badgerr closed 6 months ago
4
Pin pytest<8 to fix Python 3.11 tests

#619 wbarnha closed 6 months ago
1
Fix imports from updates in mode-streaming~=0.4.0

#618 wbarnha closed 6 months ago
0
ModuleNotFoundError: No module named 'mode.utils.typing'

#617 klajdicaushi closed 6 months ago
4
Add a method to include the whole message when using the take method

#616 fonty422 closed 6 months ago
1
Bump actions/download-artifact from 3 to 4

#614 dependabot[bot] closed 6 months ago
4
Fix prometheus registry

#613 krzysieksulejczak closed 7 months ago
1
fix: serialize (named)tuple when using orjson

#612 zevisert closed 7 months ago
1
Does Faust Streaming Consumer retry the offset commit if it fails?

#611 arcanjo45 opened 7 months ago
1
Fix disabled aiokafka unit tests

#610 wbarnha closed 6 months ago
1
Run black and update setup.cfg for flake8 to ignore E701 and E704

#609 Tim-Thomas closed 7 months ago
2
bugfix: Fix cython _on_stream_event_in call to match python impl

#608 Tim-Thomas closed 7 months ago
3
Logic around sensor _on_stream_event_in differs between cython and python implementations

#607 Tim-Thomas closed 7 months ago
0
Wrong offset commit in case of gaps

#606 vitalbbyy opened 7 months ago
0
Events getting skipped

#605 VatsalLalcheta opened 8 months ago
1
Bump codecov/codecov-action from 3 to 4

#604 dependabot[bot] closed 7 months ago
1
Closing connection

#603 Abraham-liuhai opened 8 months ago
0
Rebalancing problem with Faust Streaming

#602 arcanjo45 opened 8 months ago
0
`SetTable`s are missing `on_clear`

#601 cristianmatache opened 8 months ago
1
enable kafka static-partition-assignment (KIP-345)

#600 Mopsgeschwindigkeit closed 8 months ago
1
Bump actions/upload-artifact from 3 to 4

#599 dependabot[bot] closed 9 months ago
3
Use `loop.create_task()` for agent tasks

#598 samtx closed 9 months ago
2
Cannot recover when any changelog topic partition becomes empty (as a result of some retention policy)

#597 cristianmatache opened 9 months ago
0
A race condition in recovery causes unrecoverable gaps in acked offsets and consequently blocks committing

#596 cristianmatache opened 9 months ago
0