{"repo":"kpn/kstreams","free":true,"listed":false,"github":"https://github.com/kpn/kstreams","clone":"git clone https://github.com/kpn/kstreams.git","description":"Library/micro framework to create streaming applications with kafka in a fast way","language":"Python","stars":42,"topics":["kafka","streaming"],"license":"Apache-2.0","category":"data-pipelines","readme_excerpt":"Kstreams kstreams is a library/micro framework to use with kafka . It has simple kafka streams implementation that gives certain guarantees, see below. --- Documentation : https://kpn.github.io/kstreams/ --- Installation You will need a worker, we recommend aiorun Usage Features - [x] Produce events - [x] Consumer events with Streams - [x] Subscribe to topics by pattern - [x] Prometheus metrics and custom monitoring - [x] TestClient - [x] Custom Serialization and Deserialization - [x] Easy to integrate with any async framework. No tied to any library!! - [x] Yield events from streams - [x] Opentelemetry Instrumentation - [x] Middlewares - [x] Hooks (on startup, on stop, after startup, after stop) - [ ] Store (kafka streams pattern) - [ ] Stream Join - [ ] Windowing Development This repo requires the use of poetry instead of pip. Note : If you want to have the virtualenv in the same path as the project first you should run poetry config --local virtualenvs.in-project true To install the dependencies just execute: Then you can activate the virtualenv with Run test: Run code formatting with ruff: Commit messages We use conventional commits for the commit message. The use of commitizen is recommended. Commitizen is part of the dev dependencies.","default_branch":null,"files":null,"tree":[],"storefront":"/r/kpn","claimed":false,"request_supported":{"post":"https://gitbuyer.com/r/kpn/kstreams/request-supported","requests":0},"note":"indexed from public GitHub; nothing is for sale on this page. Clone it from GitHub. Paid listings live at /search."}