Ecosyste.ms: Packages

An open API service providing package, version and dependency metadata of many open source software ecosystems and registries.

pypi.org "kafka" keyword

esque-wire 0.1.0
A complete implementation of the Kafka API
1 version - Latest release: over 4 years ago - 1 dependent repositories - 14 downloads last month - 1 maintainer
taskiq-faststream 0.1.8 💰
FastStream - taskiq integration to schedule FastStream tasks
9 versions - Latest release: about 1 month ago - 706 downloads last month - 20 stars on GitHub - 3 maintainers
nodestream-plugin-neptune 0.12.0
A Fast, Declarative, and Extensible ETL Framework for Graph Databases.
5 versions - Latest release: about 2 months ago - 17 downloads last month - 31 stars on GitHub - 1 maintainer
kio 0.1.0
Python data types for the Apache Kafka® Protocol.
5 versions - Latest release: 16 days ago - 1 dependent repositories - 140 downloads last month - 16 stars on GitHub - 1 maintainer
Top 8.8% on pypi.org
funboost 44.4
pip install funboost，python全功能分布式函数调度框架,。支持python所有类型的并发模式和一切知名消息队列中间件，支持如 celery dramatiq等框架整体作为...
153 versions - Latest release: 19 days ago - 2 dependent packages - 1 dependent repositories - 2.07 thousand downloads last month - 630 stars on GitHub - 1 maintainer
funboost-wise 18.3
pip install funboost，python全功能分布式函数调度框架,。支持python所有类型的并发模式和一切知名消息队列中间件，支持如 celery dramatiq等框架整体作为...
1 version - Latest release: about 1 month ago - 13 downloads last month - 630 stars on GitHub - 1 maintainer
funboost-install 17.4
pip install funboost，python全功能分布式函数调度框架,。支持python所有类型的并发模式和一切知名消息队列中间件，python函数加速器，框架包罗万象，一统编程思维，...
1 version - Latest release: over 1 year ago - 15 downloads last month - 623 stars on GitHub - 1 maintainer
pfunboost 17.2
funboost is function scheduling distributed framework,support threading,gevent,eventlet,asyncio ...
2 versions - Latest release: almost 2 years ago - 25 downloads last month - 623 stars on GitHub - 1 maintainer
freeza-offset 1.0.10
Spark stream consumption commit in kafka consumer group
10 versions - Latest release: almost 4 years ago - 1 dependent repositories - 956 downloads last month - 14 stars on GitHub - 1 maintainer
esque 0.6.0
esque - an operational kafka tool.
24 versions - Latest release: 9 months ago - 1 dependent repositories - 117 downloads last month - 24 stars on GitHub - 1 maintainer
azure-functions-kafka-binding 1.0.1
Kafka extension for Azure Functions
2 versions - Latest release: about 5 years ago - 1 dependent repositories - 35 downloads last month - 112 stars on GitHub - 1 maintainer
Top 7.5% on pypi.org
faststream 0.5.6
FastStream: the simplest way to work with a messaging queues
73 versions - Latest release: 13 days ago - 3 dependent packages - 1 dependent repositories - 94.7 thousand downloads last month - 1,408 stars on GitHub - 2 maintainers
faker-events 1.6.0
Generates Events with formatted fake data for streams.
10 versions - Latest release: almost 2 years ago - 1 dependent repositories - 89 downloads last month - 5 stars on GitHub - 1 maintainer
fastkafka 0.8.0
FastKafka is a powerful and easy-to-use Python library for building asynchronous web services tha...
53 versions - Latest release: 11 months ago - 1 dependent repositories - 209 downloads last month - 33 stars on GitHub - 1 maintainer
function-scheduling-distributed-framework 13.1
function scheduling distributed framework,support threading,gevent,eventlet,asyncio concurrent,su...
103 versions - Latest release: over 2 years ago - 1 dependent repositories - 180 downloads last month - 323 stars on GitHub - 1 maintainer
Top 1.1% on pypi.org
aiokafka 0.10.0
Kafka integration with asyncio
31 versions - Latest release: 6 months ago - 55 dependent packages - 1,068 dependent repositories - 1.75 million downloads last month - 1,065 stars on GitHub - 3 maintainers
Top 4.1% on pypi.org
mypy-boto3-kafka 1.34.107 💰
Type annotations for boto3.Kafka 1.34.114 service generated with mypy-boto3-builder 7.24.0
588 versions - Latest release: 13 days ago - 3 dependent packages - 4 dependent repositories - 175 thousand downloads last month - 440 stars on GitHub - 1 maintainer
fooltrader 0.0.1a1 💰
Open source quantitative framework for Humans
1 version - Latest release: about 6 years ago - 1 dependent repositories - 11 downloads last month - 1,129 stars on GitHub - 1 maintainer
mockafka-py 0.1.55 💰
A mock library for confluent kafka
22 versions - Latest release: about 1 month ago - 3.66 thousand downloads last month - 28 stars on GitHub - 1 maintainer
kinesis-producer 0.2.1
Producer for AWS Kinesis Stream with record aggregation
3 versions - Latest release: about 8 years ago - 3 dependent repositories - 921 downloads last month - 5 stars on GitHub - 4 maintainers
muffin-kafka 0.2.6
Kafka Integration for Muffin framework
28 versions - Latest release: 2 months ago - 73 downloads last month - 0 stars on GitHub - 1 maintainer
pypz-kafka-io 0.9.1
Provides a Kafka implementation of the ChannelInput/OutputPort in pypz.
8 versions - Latest release: about 1 month ago - 454 downloads last month - 6 stars on GitHub - 1 maintainer
swissbib-kafka-event-hub 2.2.0
Swissbib Kafka Event Hub
59 versions - Latest release: about 5 years ago - 1 dependent repositories - 266 downloads last month - 1 stars on GitHub - 2 maintainers
py-avro-schema 3.6.0
Generate Apache Avro schemas for Python types including standard library data-classes and Pydanti...
44 versions - Latest release: 2 months ago - 1 dependent package - 1 dependent repositories - 10.1 thousand downloads last month - 27 stars on GitHub - 4 maintainers
json-transporter 0.2.3
A JSON data transporter
3 versions - Latest release: over 8 years ago - 2 dependent repositories - 27 downloads last month - 3 stars on GitHub - 1 maintainer
Top 8.2% on pypi.org
quixstreams 2.5.0
Python library for building stream processing applications with Apache Kafka
25 versions - Latest release: 13 days ago - 2 dependent packages - 2 dependent repositories - 1.97 thousand downloads last month - 824 stars on GitHub - 1 maintainer
pathway 1.3.1
Pathway is a data processing framework which takes care of streaming data updates for you.
46 versions - Latest release: over 14 years ago - 1 dependent package - 1 dependent repositories - 3.23 thousand downloads last month - 1,695 stars on GitHub - 4 maintainers
Top 5.6% on pypi.org
gcn-kafka 0.3.3
Kafka client for NASA's General Coordinates Network (GCN)
11 versions - Latest release: 9 months ago - 1 dependent package - 12 dependent repositories - 10.8 thousand downloads last month - 10 stars on GitHub - 2 maintainers
csharkkafkapkg 0.0.1
CShark custom kafka library for python project
1 version - Latest release: 5 months ago - 6 downloads last month - 1 maintainer
kaskade 1.1.8 💰
kaskade is a terminal user interface for kafka
31 versions - Latest release: almost 2 years ago - 1 dependent repositories - 87 downloads last month - 91 stars on GitHub - 1 maintainer
kafka-python-with-confluent-kafka 0.2
This python project use to consume/produce/manager the Kafka
2 versions - Latest release: over 5 years ago - 1 dependent repositories - 56 downloads last month - 0 stars on GitLab.com - 1 maintainer
Top 1.6% on pypi.org
pykafka 2.8.0
Full-Featured Pure-Python Kafka Client
38 versions - Latest release: over 5 years ago - 9 dependent packages - 346 dependent repositories - 173 thousand downloads last month - 1,118 stars on GitHub - 5 maintainers
timi-kafka 0.0.2
Pure Python client for Apache Kafka
2 versions - Latest release: about 5 years ago - 1 dependent repositories - 12 downloads last month - 0 stars on GitHub - 1 maintainer
Top 1.8% on pypi.org
faust 1.10.4
Python Stream processing.
46 versions - Latest release: over 4 years ago - 3 dependent packages - 274 dependent repositories - 22.9 thousand downloads last month - 6,647 stars on GitHub - 2 maintainers
kafka_influxdb 0.9.3 💰
A Kafka consumer for InfluxDB
15 versions - Latest release: almost 7 years ago - 2 dependent repositories - 40 downloads last month - 215 stars on GitHub - 1 maintainer
nameko-kafka 0.2.1
Kafka extension for Nameko microservice framework
3 versions - Latest release: 11 months ago - 1 dependent repositories - 49 downloads last month - 18 stars on GitHub - 1 maintainer
woof3 3.1
Messaging library
2 versions - Latest release: over 1 year ago - 11 downloads last month - 1 maintainer
fastmicro 0.3.2
Fast, simple microservice framework
14 versions - Latest release: over 2 years ago - 1 dependent repositories - 74 downloads last month - 1 stars on GitHub - 1 maintainer
flask-kafka-python 0.0.2
Make it easier to integrate flask with kafka
2 versions - Latest release: about 1 year ago - 27 downloads last month - 1 stars on GitHub - 1 maintainer
wunderkafka 0.16.1
librdkafka-powered client for Kafka for python with (hopefully) more handful API
28 versions - Latest release: 4 months ago - 1 dependent package - 1 dependent repositories - 254 downloads last month - 3 stars on GitHub - 1 maintainer
pulumi-kafka 3.7.4
A Pulumi package for creating and managing Kafka.
263 versions - Latest release: 20 days ago - 3 dependent repositories - 9.16 thousand downloads last month - 15 stars on GitHub - 1 maintainer
mlp-tracking 0.0.3
mlp_tracking
3 versions - Latest release: almost 3 years ago - 1 dependent repositories - 35 downloads last month - 1 maintainer
kafka-overwatch 0.4.0
Continuously monitors Kafka cluster topics & consumer groups
6 versions - Latest release: about 1 month ago - 111 downloads last month - 5 stars on GitHub - 1 maintainer
fast-kafka-api 0.0.4
Extension of FastAPI with Kafka event handlers
13 versions - Latest release: over 1 year ago - 1 dependent repositories - 141 downloads last month - 1,796 stars on GitHub - 1 maintainer
asynckafka 0.2.0
Fast python kafka client for asyncio.
5 versions - Latest release: over 3 years ago - 3 dependent repositories - 34 downloads last month - 34 stars on GitHub - 1 maintainer
logprep 11.3.0
Logprep allows to collect, process and forward log messages from various data sources.
36 versions - Latest release: 16 days ago - 408 downloads last month - 24 stars on GitHub - 3 maintainers
makinage 0.8.0
Reactive data science
10 versions - Latest release: over 2 years ago - 1 dependent repositories - 18 downloads last month - 38 stars on GitHub - 1 maintainer
Top 9.3% on pypi.org
ns-kafka-python 1.4.7
Pure Python client for Apache Kafka
1 version - Latest release: over 3 years ago - 1 dependent repositories - 169 downloads last month - 5,493 stars on GitHub - 1 maintainer
os-scrapy-kafka-pipeline 0.0.15
Kafka pipline
15 versions - Latest release: over 3 years ago - 1 dependent repositories - 31 downloads last month - 5,493 stars on GitHub - 1 maintainer
Top 8.6% on pypi.org
gc-kafka-python 0.9.8
Pure Python client for Apache Kafka
4 versions - Latest release: over 8 years ago - 2 dependent repositories - 19 downloads last month - 5,493 stars on GitHub - 1 maintainer
Top 0.8% on pypi.org
kafka 1.3.5
Pure Python client for Apache Kafka
17 versions - Latest release: over 6 years ago - 12 dependent packages - 348 dependent repositories - 287 thousand downloads last month - 5,493 stars on GitHub - 1 maintainer
Top 2.0% on pypi.org
kafka-python3 3.0.0
Pure Python client for Apache Kafka
1 version - Latest release: about 2 years ago - 1 dependent package - 32 dependent repositories - 21 thousand downloads last month - 5,493 stars on GitHub - 1 maintainer
Top 0.3% on pypi.org
kafka-python 2.0.2
Pure Python client for Apache Kafka
34 versions - Latest release: over 3 years ago - 219 dependent packages - 3,616 dependent repositories - 13.1 million downloads last month - 5,493 stars on GitHub - 2 maintainers
pyfunctest 0.0.6
The framework for functional testing of microservices
2 versions - Latest release: almost 3 years ago - 1 dependent repositories - 20 downloads last month - 1 stars on GitHub - 1 maintainer
sqlalchemy-risingwave 1.1.0
RisingWave dialect for SQLAlchemy
11 versions - Latest release: about 2 months ago - 1 dependent package - 2 dependent repositories - 15.8 thousand downloads last month - 6,401 stars on GitHub - 1 maintainer
Top 4.5% on pypi.org
dbt-materialize 1.7.8
The Materialize adapter plugin for dbt.
45 versions - Latest release: 23 days ago - 3 dependent repositories - 2.42 thousand downloads last month - 5,608 stars on GitHub - 1 maintainer
gnomock-python-sdk 1.19.0 💰
gnomock
18 versions - Latest release: over 2 years ago - 1 dependent repositories - 64 downloads last month - 1,313 stars on GitHub - 1 maintainer
jaws-scripts 4.5.4
JLab Alarm Warning System (JAWS) Admin Scripts
14 versions - Latest release: almost 2 years ago - 1 dependent repositories - 109 downloads last month - 7 stars on GitHub - 1 maintainer
pyallel-consumer 0.1.0a2
Python wrapper for Confluent Parallel Consumer
3 versions - Latest release: over 1 year ago - 98 downloads last month - 659 stars on GitHub - 1 maintainer
kpops 5.0.1
KPOps is a tool to deploy Kafka pipelines to Kubernetes
79 versions - Latest release: 15 days ago - 1.8 thousand downloads last month - 12 stars on GitHub - 1 maintainer
mdalib 0.1.8
ทดสอบ
9 versions - Latest release: over 3 years ago - 1 dependent repositories - 41 downloads last month - 1 maintainer
bdbizvizkafka 0.1
kafka connection
1 version - Latest release: over 2 years ago - 1 dependent repositories - 15 downloads last month - 0 stars on GitHub - 1 maintainer
kafkalogs 0.1.6
Kakfa logging made simple with python, make your log messages as kafka events out-of-the-box!
9 versions - Latest release: over 2 years ago - 1 dependent repositories - 22 downloads last month - 1 stars on GitHub - 1 maintainer
fjord_kafka_migration 0.2.5
fjord kafka migration tools.
22 versions - Latest release: about 6 years ago - 37 downloads last month - 1 maintainer
strimzi-kafka-cli 0.1.0a78
Command Line Interface for Strimzi Kafka Operator
78 versions - Latest release: 2 months ago - 1 dependent repositories - 543 downloads last month - 76 stars on GitHub - 1 maintainer
kafkaconnectsync 0.0.4
Kafka Connect API connectors synchronization library
4 versions - Latest release: almost 4 years ago - 1 dependent repositories - 11 downloads last month - 0 stars on GitHub - 1 maintainer
snapstream 1.0.0
Streamline your Kafka data processing, this tool aims to standardize streaming data from multiple...
17 versions - Latest release: about 2 months ago - 1.24 thousand downloads last month - 1 stars on GitHub - 1 maintainer
kafkarobotlibrary 0.1.0
Uma biblioteca do Robot Framework para interação com o Kafka.
1 version - Latest release: 2 months ago - 8 downloads last month - 1 maintainer
ayugespidertools 3.9.7
scrapy 扩展库：用于扩展 Scrapy 功能来解放双手。
89 versions - Latest release: 3 months ago - 1 dependent repositories - 287 downloads last month - 59 stars on GitHub - 1 maintainer
threatbus-misp 2022.5.16 💰
A plugin to enable threatbus communication with MISP.
26 versions - Latest release: about 2 years ago - 1 dependent repositories - 170 downloads last month - 250 stars on GitHub - 1 maintainer
pyalink-flink-1.12 1.6.2
Alink Python API
14 versions - Latest release: 7 months ago - 85 downloads last month - 3,505 stars on GitHub - 1 maintainer
pyalink-flink-1.9 1.6.2
Alink Python API
23 versions - Latest release: 7 months ago - 92 downloads last month - 3,505 stars on GitHub - 1 maintainer
pyalink-flink-1.10 1.6.2
Alink Python API
18 versions - Latest release: 7 months ago - 142 downloads last month - 3,505 stars on GitHub - 1 maintainer
pyalink 1.6.2
Alink Python API
23 versions - Latest release: 7 months ago - 238 downloads last month - 3,502 stars on GitHub - 1 maintainer
pyalink-flink-1.11 1.6.2
Alink Python API
16 versions - Latest release: 7 months ago - 93 downloads last month - 3,502 stars on GitHub - 1 maintainer
dattasa 1.1
Python wrapper for connecting to postgres/greenplum, mysql, mongodb, kafka, redis, mixpanel and s...
1 version - Latest release: over 6 years ago - 1 dependent repositories - 7 downloads last month - 4 stars on GitHub - 1 maintainer
franz 0.0.11
Event broker built on top of kafka and rabbitmq; used to handle micro services message exchange.
7 versions - Latest release: almost 6 years ago - 1 dependent repositories - 2.03 thousand downloads last month - 5 stars on GitHub - 1 maintainer
wf-dagger 0.2.6
Workflow Engine.
12 versions - Latest release: 7 months ago - 111 downloads last month - 48 stars on GitHub - 1 maintainer
syslogng_kafka 0.1.11
syslog-ng mod-python Kafka driver
12 versions - Latest release: almost 7 years ago - 160 downloads last month - 2 stars on GitHub - 1 maintainer
python-elk-kafka 0.0.1
A python3 elk project use kafka to send messages
1 version - Latest release: about 5 years ago - 1 dependent repositories - 12 downloads last month - 4 stars on GitHub - 1 maintainer
brokerstream 0.0.13
Broker stream
11 versions - Latest release: over 1 year ago - 1 dependent repositories - 63 downloads last month - 1 maintainer
langstream-ai 0.6.2
LangStream user API
34 versions - Latest release: 2 months ago - 399 downloads last month - 366 stars on GitHub - 1 maintainer
atoti-kafka 0.8.12
Plugin to load real time Kafka streams into Atoti tables
32 versions - Latest release: 27 days ago - 1 dependent package - 1 dependent repositories - 257 downloads last month - 214 stars on GitHub - 2 maintainers
pywlf 0.0.1
Common utils for python3.
1 version - Latest release: 7 months ago - 13 downloads last month - 0 stars on GitHub - 1 maintainer
cloud-builder 1.0.7
Cloud Builder
112 versions - Latest release: about 2 years ago - 1 dependent repositories - 477 downloads last month - 0 stars on GitHub - 1 maintainer
bdbkafka 0.1
kafka connection
1 version - Latest release: over 2 years ago - 1 dependent repositories - 13 downloads last month - 1 maintainer
samsara_sdk 0.5.5.0
A Python Client for Samsaza's Ingestion-API
1 version - Latest release: almost 8 years ago - 15 downloads last month - 144 stars on GitHub - 1 maintainer
Top 5.7% on pypi.org
sentry-arroyo 2.17.4 💰
Arroyo is a Python library for working with streaming data.
112 versions - Latest release: about 1 month ago - 2 dependent packages - 156 dependent repositories - 7.18 thousand downloads last month - 37 stars on GitHub - 1 maintainer
milabkafkaapi 1.1.1
An API for the milab projects with the kafka server.
14 versions - Latest release: over 1 year ago - 33 downloads last month - 1 maintainer
m-kafka-sdk-v2 1.0.1
Mobio Kafka SDK
17 versions - Latest release: 5 months ago - 7 dependent packages - 1 dependent repositories - 1.14 thousand downloads last month - 1 maintainer
Top 8.1% on pypi.org
datafaker 0.7.6
A tool for generating batch test data or stream data.
51 versions - Latest release: almost 3 years ago - 2 dependent repositories - 282 downloads last month - 607 stars on GitHub - 1 maintainer
kafka-config-bdb 0.1
kafka connection
1 version - Latest release: over 2 years ago - 1 dependent repositories - 6 downloads last month - 0 stars on GitHub - 1 maintainer
cdk-gw-tools 0.4.4
Conduktor Proxy API Client
11 versions - Latest release: 6 months ago - 1 dependent repositories - 64 downloads last month - 2 stars on GitHub - 1 maintainer
shore-kafka 2022.1.10
Replacement for confluent-kafka
3 versions - Latest release: over 2 years ago - 1 dependent repositories - 22 downloads last month - 1 maintainer
hstreamdb-api 0.6.1
HStreamDB api for Python
11 versions - Latest release: 10 months ago - 2 dependent repositories - 78 downloads last month - 691 stars on GitHub - 1 maintainer
scrapy-kafka-redis 0.0.7
Kafka and Redis based components for Scrapy.
1 version - Latest release: almost 6 years ago - 1 dependent repositories - 11 downloads last month - 44 stars on GitHub - 1 maintainer
kafka-protocol 0.1
Kafka Protocol in Puthon
1 version - Latest release: 10 months ago - 7 downloads last month - 0 stars on GitHub - 1 maintainer
robinhood-kafka-python 1.4.3
Pure Python client for Apache Kafka
5 versions - Latest release: over 5 years ago - 2 dependent repositories - 477 downloads last month - 6 stars on GitHub - 1 maintainer
kafkaesque 1.0
an easy to use kafka consumer that extends kafka-python, but follows the style of the flask server
1 version - Latest release: almost 6 years ago - 1 dependent repositories - 21 downloads last month - 3 stars on GitHub - 1 maintainer
nodestream-plugin-neo4j 0.12.2
A Fast, Declarative, and Extensible ETL Framework for Graph Databases.
7 versions - Latest release: about 1 month ago - 109 downloads last month - 31 stars on GitHub - 1 maintainer
Related Keywords
python 110 redis 32 asyncio 27 rabbitmq 23 stream-processing 21 distributed 21 python3 16 consumer 16 apache 15 apache-kafka 13 stream 13 kafka-consumer 12 kafka-producer 12 queue 12 distributed-systems 12 confluent 12 cli 12 security 11 framework 11 streaming 11 aws 11 processing 10 machine-learning 10 logging 10 scrapy 10 data 10 celery 10 kafka-streams 10 kubernetes 10 etl 9 pandas 9 neo4j 9 async 9 spark 9 mysql 8 mqtt 8 pulsar 8 apscheduler 8 task-scheduling 8 kombu 8 testing 8 kafka-connect 8 avro 8 function-scheduling 8 distributed-framework 8 rocketmq 8 nsq 8 api 8 sqlachemy 8 consume-confirm 8 timing 8 pipeline 7 messaging 7 scikit-learn 7 logstash 7 elasticsearch 7 microservices 7 zeek 7 docker 7 postgresql 7 data-analysis 6 funboost 6 declarative 6 data-science 6 bro 6 的 6 networking 6 flink 6 recommender-system 6 框架 6 real-time 6 s3 6 分布式调度 6 gevent 6 zeek-analysis 6 zeromq 6 data-engineering 6 robotframework 6 graph-embedding 5 apriori 5 recommender 5 regression 5 Kafka 5 graph-algorithms 5 fm 5 classification 5 client 5 producer 5 flink-ml 5 flink-machine-learning 5 feature-engineering 5 data-mining 5 clustering 5 disk 5 database 5 nameko 5 ksqldb 5 postgres 5 monitoring 5 ksql 5