rdkafka | cargo | Package Usage | Ecosyste.ms: Repos

so61pi/examples

0.18.0 rust/downloader/code/downloader/Cargo.lock
0.18.0 rust/downloader/code/downloader/bin-gate/Cargo.toml
0.18.0 rust/downloader/code/downloader/bin-media-downloader/Cargo.toml
0.18.0 rust/downloader/code/downloader/bin-url-grabber/Cargo.toml
0.18.0 rust/downloader/code/downloader/libcommon/Cargo.toml

Size: 30.9 MB - Last synced: 3 months ago - Pushed: over 1 year ago

Arcayr/nixpkgs Fork of NixOS/nixpkgs

Nix Packages collection & NixOS

0.32.2 pkgs/tools/misc/vector/Cargo.lock

Size: 3.5 GB - Last synced: 27 days ago - Pushed: 2 months ago

yatinmaan/tremor-runtime Fork of tremor-rs/tremor-runtime

Main Tremor Project Rust Codebase

0.27.0 Cargo.lock
0.27 Cargo.toml

Size: 12.4 MB - Last synced: about 1 year ago - Pushed: over 1 year ago

vaind/sentry-relay Fork of getsentry/relay

Sentry event forwarding and ingestion service.

0.24.0 Cargo.lock
0.24 relay-server/Cargo.toml

Size: 77.2 MB - Last synced: 9 months ago - Pushed: about 1 year ago

abijithanikkuruthi/MessageScheduler

Scheduled Message delivery implementation in Apache Kafka

0.25.0 MessageHandler/Cargo.lock
0.25 MessageHandler/Cargo.toml
0.28.0 Worker/Cargo.lock
0.28.0 Worker/Cargo.toml

Size: 924 KB - Last synced: about 1 year ago - Pushed: almost 2 years ago

jakeswenson/vector Fork of vectordotdev/vector

A lightweight and ultra-fast tool for building observability pipelines

0.23.1 Cargo.lock
0.23.1 Cargo.toml

Size: 18.6 MB - Last synced: about 1 year ago - Pushed: over 1 year ago

Oyelowo/coding_practice

0.24.0 rust/modern_web/Cargo.lock
0.24.0 rust/modern_web/Cargo.toml

Size: 131 MB - Last synced: 23 days ago - Pushed: 23 days ago

jaco1986/shiftm

0.23.1 Cargo.lock
0.23.1 Cargo.toml

Size: 178 MB - Last synced: about 1 year ago - Pushed: over 1 year ago

swilcox3/kafka-cad

Real-time collaborative architectural CAD in your browser. Based on Kafka, gRPC, Redis, and OpenCASCADE.

0.23.1 Cargo.lock
0.23.1 dependencies/Cargo.toml
0.23.1 objects/Cargo.toml
0.23.1 rep_cache/Cargo.toml
0.23.1 representations/Cargo.toml
0.23.1 submit/Cargo.toml
0.23.1 undo/Cargo.toml
0.23.1 updates/Cargo.toml

Size: 1.64 MB - Last synced: about 1 year ago - Pushed: over 1 year ago

fluidex/dingir-exchange

A high performance crypto trading engine

0.26.0 Cargo.lock

Size: 1.24 MB - Last synced: 4 months ago - Pushed: over 1 year ago

thoughtworks/epirust

An agent-based epidemiology simulation framework built in Rust

0.23 engine/Cargo.toml
0.23 orchestrator/Cargo.toml

Size: 4.3 MB - Last synced: 24 days ago - Pushed: 3 months ago

Perpetual-Altruism-Ltd/xorc-notifications Fork of xray-tech/xorc-notifications

A consumer to send push notifications from Kafka

0.23.1 Cargo.lock
0.23.1 Cargo.toml

Size: 98.6 KB - Last synced: about 1 year ago - Pushed: almost 2 years ago

jeanlouisboudart/kafka-producer-benchmark

Simple benchmark to compare different Kafka clients performance with similar configuration.

0.28 rust-producer-sync/Cargo.toml

Size: 533 KB - Last synced: 16 days ago - Pushed: over 1 year ago

Informasjonsforvaltning/fdk-mqa-property-checker

0.28.0 Cargo.lock
0.28 Cargo.toml

Size: 117 KB - Last synced: 5 months ago - Pushed: 5 months ago

JasonThon/lightflus

A Lightweight, Cloud-Native Stateful Distributed Dataflow Engine

0.29.0 Cargo.lock
0.29.0 src/common/Cargo.toml

Size: 1.86 MB - Last synced: about 1 month ago - Pushed: about 1 year ago

TimelyDataflow/timely-dataflow

A modular implementation of timely dataflow in Rust

0.23.0 kafkaesque/Cargo.toml

Size: 8.34 MB - Last synced: 4 days ago - Pushed: 4 days ago

njasm/vector Fork of vectordotdev/vector

A high-performance, high-reliability observability data pipeline.

0.26.0 Cargo.lock
0.26.0 Cargo.toml

Size: 34.6 MB - Last synced: about 1 year ago - Pushed: about 1 year ago

MorningSong/vector Fork of vectordotdev/vector

A lightweight and ultra-fast tool for building observability pipelines

0.27.0 Cargo.lock
0.27.0 Cargo.toml

Size: 68.9 MB - Last synced: 27 days ago - Pushed: 27 days ago

jdrouet/vector Fork of vectordotdev/vector

A high-performance, high-reliability observability data pipeline.

0.26.0 Cargo.lock
0.26.0 Cargo.toml

Size: 43.2 MB - Last synced: 9 months ago - Pushed: 9 months ago

DEIPworld/deip-node

Implementation of DEIP Creator Economy Protocol on the substrate-based chain connected to Octopus network

=0.26.0 event-proxy/Cargo.toml
=0.26.0 event-proxy-client/Cargo.toml

Size: 50.9 MB - Last synced: about 1 year ago - Pushed: over 1 year ago

drogue-iot/drogue-cloud

Cloud Native IoT

0.28.0 Cargo.lock
0.28 endpoint-common/Cargo.toml
0.28 event-common/Cargo.toml
0.28 integration-common/Cargo.toml
0.28 registry-events/Cargo.toml
* service-api/Cargo.toml
0.28.0 topic-admin-operator/Cargo.toml

Size: 6.41 MB - Last synced: 8 days ago - Pushed: 12 months ago

f1shl3gs/vertex

Collector for metrics, logs, traces

0.28.0 Cargo.lock
0.28.0 Cargo.toml

Size: 49.6 MB - Last synced: 23 days ago - Pushed: 23 days ago

losfair/blueboat

All-in-one, multi-tenant serverless JavaScript runtime.

0.28.0 Cargo.lock
0.28.0 Cargo.toml

Size: 1.33 MB - Last synced: 14 days ago - Pushed: about 1 year ago

kindredgroup/talos

Ecosystem for Talos Certifier - Implementation of STRIDE algorithm for strict serializable certification of distributed transactions

0.29.0 Cargo.lock
0.29.0 packages/talos_certifier_adapters/Cargo.toml

Size: 8.98 MB - Last synced: 27 days ago - Pushed: 5 months ago

cloudevents/sdk-rust

Rust library to interact with CloudEvents

^0.28 example-projects/rdkafka-example/Cargo.toml

Size: 729 KB - Last synced: 9 days ago - Pushed: 10 days ago

Informasjonsforvaltning/fdk-mqa-url-checker

0.28.0 Cargo.lock
0.28 Cargo.toml

Size: 188 KB - Last synced: 5 months ago - Pushed: 5 months ago

smhmayboudi/fip

A structure for your monorepository microservices grpc project.

0.28.0 Cargo.lock
0.28.0 fip_common/Cargo.toml

Size: 558 KB - Last synced: about 1 year ago - Pushed: about 1 year ago

delta-io/kafka-delta-ingest

A highly efficient daemon for streaming data from Kafka into Delta Lake

0.28.0 Cargo.lock
0.28 Cargo.toml

Size: 1.8 MB - Last synced: 4 months ago - Pushed: 4 months ago

Sybl-ml/dodona

Sybl Machine Learning Platform

0.26.0 backend/Cargo.lock
0.26.0 backend/analytics/Cargo.toml
0.26.0 backend/api-server/Cargo.toml
0.26.0 backend/dcl/Cargo.toml
0.26.0 backend/messages/Cargo.toml

Size: 11.8 MB - Last synced: 16 days ago - Pushed: about 1 year ago

odysa/risingwave Fork of risingwavelabs/risingwave

RisingWave: the next-generation streaming database in the cloud.

=0.2.14-alpha src/connector/Cargo.toml

Size: 60.3 MB - Last synced: about 1 year ago - Pushed: about 1 year ago

IndustryFusion/DigitalTwin

This repository contains the ingredients for the Digital Twin Concept of Industry Fusion.

0.28.0 gateway/Cargo.lock
0.28 gateway/Cargo.toml

Size: 1.7 MB - Last synced: 27 days ago - Pushed: 28 days ago

sycured/rbl-checker

Help you to check if any IP in your IP range is blacklisted

0.28.0 rust/checker/Cargo.lock
0.28.0 rust/checker/Cargo.toml
0.28.0 rust/rest_api/Cargo.lock
0.28.0 rust/rest_api/Cargo.toml

Size: 707 KB - Last synced: 6 days ago - Pushed: 7 days ago

Blockdaemon/solana-accountsdb-plugin-kafka

Solana geyser plugin implementing a Kafka publisher

0.28 Cargo.toml

Size: 473 KB - Last synced: 2 days ago - Pushed: 2 days ago

Informasjonsforvaltning/fdk-mqa-scoring-service

0.28.0 Cargo.lock
0.28.0 Cargo.toml

Size: 307 KB - Last synced: 5 months ago - Pushed: 5 months ago

bytewax/bytewax

Python Stream Processing

0.28.0 Cargo.lock
0.28.0 Cargo.toml

Size: 10.3 MB - Last synced: about 12 hours ago - Pushed: about 18 hours ago

godwokenrises/godwoken-scripts 📦

Godwoken scripts is moved to monorepo https://github.com/godwokenrises/godwoken

0.25.0 Cargo.lock

Size: 3.24 MB - Last synced: about 2 months ago - Pushed: over 1 year ago

FinnDore/kafka-tools

Some usefull kafka tools

0.28.0 apps/tauri-client/src-tauri/Cargo.lock

Size: 897 KB - Last synced: 8 days ago - Pushed: over 1 year ago

izihawa/summa

Full-text IPFS-friendly and WASM-compatible Search in Rust

0.28.0 Cargo.lock
0.28.0 Cargo.toml

Size: 7.82 MB - Last synced: 1 day ago - Pushed: 20 days ago

SquireOfSoftware/ma_and_pas

A test for RedPanda

0.25 Cargo.toml

Size: 502 KB - Last synced: 7 months ago - Pushed: 7 months ago

dennis84/blah

0.10.0 blah-collection/processing/Cargo.lock
0.10 blah-collection/processing/Cargo.toml
0.7.0 blah-data/Cargo.lock
0.7 blah-data/Cargo.toml
0.7.0 blah-events/Cargo.lock
0.7 blah-events/Cargo.toml

Size: 27.3 MB - Last synced: 27 days ago - Pushed: almost 7 years ago

mgiachetti/kafka-dump

0.24.0 Cargo.lock
0.24 Cargo.toml

Size: 45.9 KB - Last synced: about 1 year ago - Pushed: almost 2 years ago

Center-Sun/suricata-kafka-output

provides a Suricata Eve output for Kafka with Suricate Eve plugin

0.25 Cargo.toml

Size: 6.84 KB - Last synced: 25 days ago - Pushed: over 2 years ago

nolik/kit

KIT (Kafka intuitive toolkit) written on Rust.

0.28.0 Cargo.lock

Size: 74.2 KB - Last synced: about 1 year ago - Pushed: over 1 year ago

dbcfd/vector Fork of vectordotdev/vector

A high-performance observability data pipeline.

0.26.0 Cargo.lock

Size: 83.2 MB - Last synced: about 1 year ago - Pushed: over 1 year ago

Package Usage: cargo: rdkafka

Dependent Repos 536