kpn/kstreams issues and pull requests

#45 - Add a simple `run` to the `StreamEngine`

Issue - State: closed - Opened by woile over 2 years ago - 1 comment

#45 - Add a simple `run` to the `StreamEngine`

Issue - State: closed - Opened by woile over 2 years ago - 1 comment

#44 - refactor: remove the `value_` prefix from `value_serializer` and `val…

Pull Request - State: closed - Opened by woile over 2 years ago - 1 comment

#44 - refactor: remove the `value_` prefix from `value_serializer` and `val…

Pull Request - State: closed - Opened by woile over 2 years ago - 1 comment

#43 - Use serializer/deserialize

Issue - State: closed - Opened by woile over 2 years ago

#43 - Use serializer/deserialize

Issue - State: closed - Opened by woile over 2 years ago

#42 - docs: adds example processor

Pull Request - State: closed - Opened by reidmeyer over 2 years ago - 2 comments

#42 - docs: adds example processor

Pull Request - State: closed - Opened by reidmeyer over 2 years ago - 2 comments

#41 - Wrong comment in stream.py

Issue - State: closed - Opened by woile over 2 years ago
Labels: bug

#41 - Wrong comment in stream.py

Issue - State: closed - Opened by woile over 2 years ago
Labels: bug

#40 - fix: remove unsubscribe before stopping consumer

Pull Request - State: closed - Opened by marcosschroh over 2 years ago - 1 comment

#39 - fix: typing

Pull Request - State: closed - Opened by marcosschroh over 2 years ago - 1 comment

#38 - Improve ConsumerRecord

Issue - State: closed - Opened by woile over 2 years ago - 1 comment

#37 - fix: unsubscribe consumer before stopping

Pull Request - State: closed - Opened by marcosschroh over 2 years ago - 2 comments

#36 - Ci/corrections

Pull Request - State: closed - Opened by woile over 2 years ago - 1 comment

#35 - feat: add kafka backend module

Pull Request - State: closed - Opened by woile over 2 years ago - 4 comments

#34 - fix: remove stream base class

Pull Request - State: closed - Opened by marcosschroh over 2 years ago - 1 comment

#33 - Keep local state

Issue - State: open - Opened by woile over 2 years ago
Labels: enhancement

#32 - build: confluent example added. Close #2

Pull Request - State: closed - Opened by marcosschroh over 2 years ago - 1 comment

#31 - Fix/sse example

Pull Request - State: closed - Opened by marcosschroh over 2 years ago

#30 - build: fastapi example fixed

Pull Request - State: closed - Opened by marcosschroh over 2 years ago - 1 comment

#29 - Fix/stream docs

Pull Request - State: closed - Opened by marcosschroh over 2 years ago - 1 comment

#28 - feat: add streams instances without decorator

Pull Request - State: closed - Opened by marcosschroh over 2 years ago - 1 comment

#27 - fix: call serialization methods only when value is present

Pull Request - State: closed - Opened by marcosschroh over 2 years ago

#26 - add mypy and some typehints

Pull Request - State: closed - Opened by woile over 2 years ago - 1 comment

#25 - build: dataclasses-avroschema example added. Closes #3

Pull Request - State: closed - Opened by marcosschroh over 2 years ago

#24 - fix: replace engine initializers methods with start and stop

Pull Request - State: closed - Opened by marcosschroh over 2 years ago - 1 comment

#23 - build: sse example added. Closes #5

Pull Request - State: closed - Opened by marcosschroh over 2 years ago

#22 - feat: add cluster scripts

Pull Request - State: closed - Opened by woile over 2 years ago - 1 comment

#21 - docs: add kpn-theme

Pull Request - State: closed - Opened by woile over 2 years ago - 1 comment

#20 - Monitoring documentation missing

Issue - State: closed - Opened by marcosschroh over 2 years ago - 1 comment

#19 - fix: pipeline tag filter

Pull Request - State: closed - Opened by woile over 2 years ago - 1 comment

#18 - ci(pythonpublish): starts with number

Pull Request - State: closed - Opened by woile over 2 years ago - 1 comment

#17 - feat: Yield from stream. Closes #4

Pull Request - State: closed - Opened by marcosschroh over 2 years ago - 1 comment

#16 - Add mypy

Issue - State: closed - Opened by marcosschroh over 2 years ago

#15 - Cleanup prometheus metrics after Rebalancing

Issue - State: closed - Opened by marcosschroh over 2 years ago - 1 comment

#14 - Document StreamEngine API

Issue - State: closed - Opened by marcosschroh over 2 years ago - 2 comments
Labels: documentation, good first issue

#13 - Create LICENSE

Pull Request - State: closed - Opened by marcosschroh over 2 years ago - 1 comment

#12 - Replace Makefile with scripts

Issue - State: closed - Opened by marcosschroh over 2 years ago - 2 comments

#11 - Add processor example

Issue - State: closed - Opened by marcosschroh over 2 years ago - 1 comment

#10 - ci: update build publish workflow

Pull Request - State: closed - Opened by marcosschroh over 2 years ago - 1 comment

#9 - Update ValueDeserializer protocol docstring

Issue - State: closed - Opened by marcosschroh over 2 years ago - 1 comment
Labels: documentation, good first issue

#8 - docs: build badge updated and github token added in bump-version step

Pull Request - State: closed - Opened by marcosschroh over 2 years ago

#7 - Get rid of the singlenton

Issue - State: closed - Opened by marcosschroh over 2 years ago - 1 comment

#6 - Remove pkgsettings

Issue - State: closed - Opened by marcosschroh over 2 years ago - 7 comments

#5 - Add SSE example

Issue - State: closed - Opened by marcosschroh over 2 years ago

#4 - Add posibility to yield events from streams

Issue - State: closed - Opened by marcosschroh over 2 years ago

#3 - Add dataclasses-avroschema example

Issue - State: closed - Opened by marcosschroh over 2 years ago

#2 - Add Confluent example

Issue - State: closed - Opened by marcosschroh over 2 years ago

#1 - ci: github actions added

Pull Request - State: closed - Opened by marcosschroh over 2 years ago - 1 comment

GitHub / kpn/kstreams issues and pull requests