Ecosyste.ms: Issues
An open API service for providing issue and pull request metadata for open source projects.
GitHub / kpn/kstreams issues and pull requests
#234 - Uncaught ConsumerStoppedError exceptions on closed streams
Issue -
State: open - Opened by JeroennC 11 days ago
Labels: bug
#233 - build(deps-dev): bump mkdocs-material from 9.5.42 to 9.5.43
Pull Request -
State: open - Opened by dependabot[bot] 14 days ago
- 1 comment
Labels: dependencies, python
#232 - Fix/setup type
Pull Request -
State: closed - Opened by woile 17 days ago
- 2 comments
#231 - build(deps): bump softprops/action-gh-release from 1 to 2
Pull Request -
State: open - Opened by dependabot[bot] 21 days ago
- 1 comment
Labels: dependencies, github_actions
#230 - build(deps-dev): bump ruff from 0.7.0 to 0.7.1
Pull Request -
State: closed - Opened by dependabot[bot] 21 days ago
- 1 comment
Labels: dependencies, python
#229 - build(deps-dev): bump mypy from 1.12.1 to 1.13.0
Pull Request -
State: open - Opened by dependabot[bot] 21 days ago
- 1 comment
Labels: dependencies, python
#228 - build(deps-dev): bump commitizen from 3.29.1 to 3.30.0
Pull Request -
State: open - Opened by dependabot[bot] 21 days ago
- 1 comment
Labels: dependencies, python
#227 - build(deps-dev): bump fastapi from 0.115.2 to 0.115.4
Pull Request -
State: open - Opened by dependabot[bot] 21 days ago
- 1 comment
Labels: dependencies, python
#226 - UDF middleware cannot handle ConsumerRecord with specified generic typing
Issue -
State: open - Opened by JeroennC 27 days ago
- 2 comments
#225 - build(deps-dev): bump ruff from 0.6.9 to 0.7.0
Pull Request -
State: closed - Opened by dependabot[bot] 28 days ago
- 2 comments
Labels: dependencies, python
#224 - build(deps-dev): bump mypy from 1.12.0 to 1.12.1
Pull Request -
State: closed - Opened by dependabot[bot] 28 days ago
- 2 comments
Labels: dependencies, python
#223 - build(deps-dev): bump mkdocs-material from 9.5.41 to 9.5.42
Pull Request -
State: closed - Opened by dependabot[bot] 28 days ago
- 2 comments
Labels: dependencies, python
#222 - build(deps): bump actions/checkout from 3 to 4
Pull Request -
State: closed - Opened by dependabot[bot] about 1 month ago
- 2 comments
Labels: dependencies, github_actions
#221 - build(deps): bump peaceiris/actions-gh-pages from 3 to 4
Pull Request -
State: closed - Opened by dependabot[bot] about 1 month ago
- 2 comments
Labels: dependencies, github_actions
#220 - build(deps): bump codecov/codecov-action from 4.5.0 to 4.6.0
Pull Request -
State: closed - Opened by dependabot[bot] about 1 month ago
- 2 comments
Labels: dependencies, github_actions
#219 - build(deps): bump actions/setup-python from 4 to 5
Pull Request -
State: closed - Opened by dependabot[bot] about 1 month ago
- 2 comments
Labels: dependencies, github_actions
#218 - build(deps): bump actions/cache from 3 to 4
Pull Request -
State: closed - Opened by dependabot[bot] about 1 month ago
- 1 comment
Labels: dependencies, github_actions
#217 - ci: dependabot added
Pull Request -
State: closed - Opened by marcosschroh about 1 month ago
- 1 comment
#216 - fix(test_client): use proper type hint in Producer.send
Pull Request -
State: closed - Opened by woile about 1 month ago
- 2 comments
#215 - fix: move consumer record to kstreams
Pull Request -
State: closed - Opened by woile about 1 month ago
- 2 comments
#214 - build(deps-dev): bump starlette from 0.38.6 to 0.40.0
Pull Request -
State: closed - Opened by dependabot[bot] about 1 month ago
- 2 comments
Labels: dependencies
#213 - fix: add maintainer instead of author
Pull Request -
State: closed - Opened by woile about 1 month ago
- 2 comments
#212 - FIX: Update DeprecationWarnings
Pull Request -
State: closed - Opened by woile about 1 month ago
- 2 comments
#211 - fix: bump ruff dep and format files
Pull Request -
State: closed - Opened by woile about 1 month ago
- 2 comments
#210 - fix: bump dependencies
Pull Request -
State: closed - Opened by woile about 1 month ago
- 2 comments
#209 - refactor: expose a Stream.get_middleware function
Pull Request -
State: closed - Opened by woile about 1 month ago
- 2 comments
#208 - docs: large projects documentation/tutorial added
Pull Request -
State: closed - Opened by marcosschroh 2 months ago
- 2 comments
#207 - feat: error policy STOP_APPLICATION added. Closes #162
Pull Request -
State: closed - Opened by marcosschroh 3 months ago
- 2 comments
#206 - feat: Stream error policy added
Pull Request -
State: closed - Opened by marcosschroh 3 months ago
- 2 comments
#205 - chore: commitizen config updted to use poetry as version provider
Pull Request -
State: closed - Opened by marcosschroh 3 months ago
- 1 comment
#204 - check whether Stream is running when TestStreamClient is leaving the context. This allows to send more events after a Stream has crashed and still the TestStreamClient will be able to leave the context without hanging
Pull Request -
State: closed - Opened by marcosschroh 3 months ago
- 1 comment
#203 - build(deps): bump certifi from 2024.6.2 to 2024.7.4 in /examples/confluent-example
Pull Request -
State: closed - Opened by dependabot[bot] 3 months ago
- 1 comment
Labels: dependencies
#202 - feat: add Send type hint parameter to udf when a Stream is defined
Pull Request -
State: closed - Opened by marcosschroh 3 months ago
- 1 comment
#201 - FIX: update kafka
Pull Request -
State: closed - Opened by reidmeyer 3 months ago
- 2 comments
#200 - docs: search enabled
Pull Request -
State: closed - Opened by marcosschroh 4 months ago
- 1 comment
#199 - feat: subscribe topics by pattern
Pull Request -
State: closed - Opened by marcosschroh 4 months ago
- 1 comment
#198 - build(deps-dev): bump zipp from 3.17.0 to 3.19.1
Pull Request -
State: closed - Opened by dependabot[bot] 4 months ago
Labels: dependencies
#197 - test: StreamEngine and Stream tests refactored
Pull Request -
State: closed - Opened by marcosschroh 4 months ago
#196 - docs: ssl example added
Pull Request -
State: closed - Opened by marcosschroh 4 months ago
- 1 comment
#195 - docs: backend documentation updated. Closes #192
Pull Request -
State: closed - Opened by marcosschroh 4 months ago
- 1 comment
#194 - build(deps-dev): bump certifi from 2023.7.22 to 2024.7.4
Pull Request -
State: closed - Opened by dependabot[bot] 4 months ago
- 2 comments
Labels: dependencies
#193 - feat: StreamEngine hooks on_startup, on_stop, after_startup and after…
Pull Request -
State: closed - Opened by marcosschroh 5 months ago
- 2 comments
#192 - Update utils documentation
Issue -
State: closed - Opened by woile 5 months ago
#191 - fix: always subscribe to topics when a Stream is started. Multiple ca…
Pull Request -
State: closed - Opened by marcosschroh 5 months ago
- 1 comment
#190 - feat(structured-concurrency): first step to introduce structured conc…
Pull Request -
State: closed - Opened by marcosschroh 5 months ago
- 1 comment
#189 - fix: stop properly a stream when it crashes from ExceptionMiddleware
Pull Request -
State: closed - Opened by marcosschroh 5 months ago
- 3 comments
#188 - docs: backend docs updated with SSL example
Pull Request -
State: closed - Opened by marcosschroh 5 months ago
- 1 comment
#187 - docs: backend docs updated with SSL example
Pull Request -
State: closed - Opened by marcosschroh 5 months ago
#186 - build(deps-dev): bump urllib3 from 2.0.7 to 2.2.2
Pull Request -
State: closed - Opened by dependabot[bot] 5 months ago
Labels: dependencies
#184 - docs: fix serialization page code example tabulation
Pull Request -
State: closed - Opened by Lancetnik 6 months ago
- 2 comments
#183 - ci: codecov step fixed
Pull Request -
State: closed - Opened by marcosschroh 6 months ago
#182 - build(deps-dev): bump requests from 2.31.0 to 2.32.0
Pull Request -
State: closed - Opened by dependabot[bot] 6 months ago
Labels: dependencies
#181 - fix: log possible error in the typed handler wrapper
Pull Request -
State: closed - Opened by eigenein 6 months ago
- 1 comment
Labels: enhancement
#180 - build(deps-dev): bump jinja2 from 3.1.3 to 3.1.4
Pull Request -
State: closed - Opened by dependabot[bot] 7 months ago
Labels: dependencies
#179 - build(deps-dev): bump werkzeug from 2.3.7 to 3.0.3
Pull Request -
State: open - Opened by dependabot[bot] 7 months ago
- 2 comments
Labels: dependencies
#178 - build(deps): bump pydantic from 1.10.5 to 1.10.13 in /examples/stream-with-manual-commit
Pull Request -
State: closed - Opened by dependabot[bot] 7 months ago
- 2 comments
Labels: dependencies
#177 - build(deps): bump pydantic from 2.3.0 to 2.4.0
Pull Request -
State: closed - Opened by dependabot[bot] 7 months ago
- 1 comment
Labels: dependencies
#176 - build(deps): bump idna from 3.6 to 3.7 in /examples/fastapi-sse
Pull Request -
State: closed - Opened by dependabot[bot] 7 months ago
Labels: dependencies
#175 - build(deps): bump idna from 3.6 to 3.7 in /examples/confluent-example
Pull Request -
State: closed - Opened by dependabot[bot] 7 months ago
Labels: dependencies
#174 - build(deps): bump idna from 3.6 to 3.7 in /examples/fastapi-webapp
Pull Request -
State: closed - Opened by dependabot[bot] 7 months ago
Labels: dependencies
#173 - build(deps-dev): bump idna from 3.4 to 3.7
Pull Request -
State: closed - Opened by dependabot[bot] 7 months ago
- 2 comments
Labels: dependencies
#172 - fix: deserializer deprecation warning added. Examples with deserializ…
Pull Request -
State: closed - Opened by marcosschroh 9 months ago
- 2 comments
#171 - fix(StreamEngine): graceful shutdown must wait for all events to be p…
Pull Request -
State: closed - Opened by marcosschroh 9 months ago
- 5 comments
#170 - build(deps): bump fastapi from 0.79.1 to 0.109.1 in /examples/fastapi-webapp
Pull Request -
State: closed - Opened by dependabot[bot] 10 months ago
- 1 comment
Labels: dependencies
#169 - build(deps): bump fastapi from 0.108.0 to 0.109.1 in /examples/fastapi-sse
Pull Request -
State: closed - Opened by dependabot[bot] 10 months ago
- 1 comment
Labels: dependencies
#168 - build(deps-dev): bump fastapi from 0.103.1 to 0.109.1
Pull Request -
State: closed - Opened by dependabot[bot] 10 months ago
- 1 comment
Labels: dependencies
#167 - fix: make sure that there is not an asyncio.Task when udf is an asyn…
Pull Request -
State: closed - Opened by marcosschroh 10 months ago
- 2 comments
#166 - feat(TestStreamClient): support custom classes for test consumers and producers
Pull Request -
State: closed - Opened by JeroennC 10 months ago
- 2 comments
#165 - fix: mypy updated from version 0.9 to 1.8.0. Some typing fixed. Close…
Pull Request -
State: closed - Opened by marcosschroh 10 months ago
- 1 comment
#164 - fix: aiorun dependency removed
Pull Request -
State: closed - Opened by marcosschroh 10 months ago
- 2 comments
#163 - Declarative streams as class methods
Issue -
State: open - Opened by JeroennC 10 months ago
#162 - Graceful Shutdown
Issue -
State: closed - Opened by JeroennC 10 months ago
- 4 comments
#161 - fix: coroutine anext introduced for python versions lower than 3.10
Pull Request -
State: closed - Opened by marcosschroh 10 months ago
- 1 comment
#160 - fix(pyproject.toml): Lock pydantic on > 2.0 because it is not compatible with 1.x since v0.15.2
Pull Request -
State: closed - Opened by gmmcal 10 months ago
- 1 comment
#159 - Bump mypy and fix it's issues
Issue -
State: closed - Opened by woile 10 months ago
#158 - build(deps-dev): bump jinja2 from 3.1.2 to 3.1.3
Pull Request -
State: closed - Opened by dependabot[bot] 10 months ago
- 1 comment
Labels: dependencies
#157 - break(AsyncGenerator): Stream as async generators (yield from stream)…
Pull Request -
State: closed - Opened by marcosschroh 10 months ago
- 2 comments
#156 - refactor: Updated code to Pydantic 2.0 (get rid of deprecation warnings)
Pull Request -
State: closed - Opened by wpeterw 10 months ago
- 1 comment
#155 - feat: Middleware capability introduced
Pull Request -
State: closed - Opened by marcosschroh 11 months ago
- 3 comments
#154 - chore: ruff config added. Make use of ruff formatter
Pull Request -
State: closed - Opened by marcosschroh 11 months ago
- 1 comment
#153 - build(deps): bump aiokafka from 0.8.1 to 0.10.0. ruff added in order to replace isort, flake8 and black
Pull Request -
State: closed - Opened by marcosschroh 11 months ago
- 1 comment
#152 - chore: migrate consume multiple topics example to a proper project structure
Pull Request -
State: closed - Opened by alxdrcirilo 11 months ago
- 3 comments
#151 - Add timeout to `TestStreamClient.get_event`
Issue -
State: closed - Opened by woile 11 months ago
- 4 comments
Labels: enhancement
#150 - fix(Stream): handle errors.ConsumerStoppedError exception for the new…
Pull Request -
State: closed - Opened by marcosschroh 11 months ago
- 1 comment
#149 - feat(TestStreamClient): add ability to create extra topics before the…
Pull Request -
State: closed - Opened by marcosschroh 11 months ago
- 2 comments
#148 - feat: migrate simple example to a proper project structure
Pull Request -
State: closed - Opened by alxdrcirilo 11 months ago
#145 - Migrate consume_multiple_topics.py example to a proper project structure
Issue -
State: closed - Opened by marcosschroh 11 months ago
- 1 comment
Labels: good first issue, examples
#144 - Migrate json_serialization.py example to a proper project structure
Issue -
State: open - Opened by marcosschroh 11 months ago
Labels: good first issue, examples
#140 - feat: first steps to add dependency injection. Inspect udf coroutines…
Pull Request -
State: closed - Opened by marcosschroh 12 months ago
#135 - build(deps-dev): bump werkzeug from 2.3.7 to 3.0.1
Pull Request -
State: closed - Opened by dependabot[bot] about 1 year ago
- 1 comment
Labels: dependencies
#129 - FIX: remove stop from remove stream
Pull Request -
State: closed - Opened by reidmeyer over 1 year ago
- 2 comments
#126 - fix: end_offsets off by 1
Pull Request -
State: closed - Opened by reidmeyer over 1 year ago
- 2 comments
#123 - docs: test build docs PR
Pull Request -
State: closed - Opened by marcosschroh over 1 year ago
- 1 comment
#119 - Fix/deps hotfix
Pull Request -
State: closed - Opened by woile over 1 year ago
- 1 comment
#118 - docs: improve example
Pull Request -
State: closed - Opened by woile over 1 year ago
#100 - feat: RebalanceListener interface added so a rebalance listener can b…
Pull Request -
State: closed - Opened by marcosschroh over 1 year ago
- 1 comment
#100 - feat: RebalanceListener interface added so a rebalance listener can b…
Pull Request -
State: closed - Opened by marcosschroh over 1 year ago
- 1 comment
#99 - docs: StreamEngine and Streams documentation added.
Pull Request -
State: closed - Opened by marcosschroh over 1 year ago
- 1 comment
#99 - docs: StreamEngine and Streams documentation added.
Pull Request -
State: closed - Opened by marcosschroh over 1 year ago
- 1 comment
#98 - fix: dependencies updated
Pull Request -
State: closed - Opened by marcosschroh over 1 year ago
- 1 comment