Lib.rs

› 关键词 ##apache-kafka ##async ##redpanda ##topic ##api-bindings ##client

##kafka

  1. rdkafka

    Rust 对 librdkafka 的封装

    v0.36.2 567K ##producer-consumer ##apache-kafka ##kafka ##message ##offset ##partition ##broker

  2. schema_registry_converter

    使用 Confluent Schema Registry 对 Kafka 中的数据进行编码和解码

    v4.1.0 31K ##json-schema ##schema ##kafka ##avro ##protobuf ##codec ##async-version

  3. ksunami

    生产恒定、可配置的循环波形的 Kafka 记录

    v0.1.10 ##kafka ##workload ##performance ##performance-testing ##developer-tools ##random-key ##command-line-tool

  4. kafka-protocol

    Kafka 线协议

    v0.11.0 10K ##api-version ##fields ##kafka ##protocols

  5. kommitted

    测量 Kafka 消费者偏移量滞后和时间滞后

    v0.3.1 ##kafka ##consumer-group ##monitoring ##performance ##lag ##consume ##prometheus-metrics

  6. aws-sdk-kafka

    AWS SDK 用于 Kafka 的托管流服务

    v1.42.0 650 ##aws-sdk ##cluster ##operation ##amazon ##kafka ##client ##msk

  7. aws-sdk-kafkaconnect

    AWS SDK 用于 Kafka Connect 的托管流服务

    v1.40.0 550 ##aws-sdk ##kafka ##connect ##operation ##managed ##streaming ##client

  8. sea-streamer

    🌊 Rust 的流处理工具包

    v0.5.0 2.2K ##async-stream ##stream-processing ##stream ##kafka ##async-io ##async ##async-api

  9. rskafka

    Apache Kafka 的最小 Rust 客户端

    v0.5.0 5.7K ##apache-kafka ##kafka ##write-ahead-log ##protocols ##async ##api ##consumer-group

  10. samsa

    Rust 原生 Kafka/Redpanda 协议和客户端实现

    v0.1.7 130 ##producer-consumer ##apache-kafka ##kafka ##redpanda ##confluent ##memory-safety ##api-bindings

  11. ##kafka

    Rust 的 Apache Kafka 客户端

    v0.10.0 18K #apache-kafka #queue #client #topic #producer #deprecated #consumer

  12. rumqttd

    使用 Rust 编写的轻量级、可嵌入的高性能 MQTT 代理

    v0.19.0 1.7K #mqtt #iot #broker #nats #kafka #light-weight #config-file

  13. mq-workload-generator

    测试 Apache RocketMQ 和 Apache Kafka 的性能

    v0.2.2 280 #apache-kafka #performance-testing #kafka #rocket-mq #benchmark #message #testing

  14. picokafka

    基于 librdkafka 的 tarantool-module 的 Kafka 库

    v0.3.0 340 #tarantool #kafka #distributed-systems #communication #thread #consumer #driver

  15. sentry-kafka-schemas

    Sentry 的 Kafka 主题和模式

    v0.1.106 3.3K #json-schema #schema-definition #sentry #kafka #topic #messages #directory

  16. rdkafka-sys

    librdkafka 库的原生绑定

    v4.7.0+2.3.0 495K #apache-kafka #native-bindings #kafka #rdkafka #version #librdkafka #build

  17. flowgger

    快速、简单且轻量级的数据收集器

    v0.3.3 #collector #log-format #remote #kafka #protocols #data-store #input

  18. shotover

    用于构建自定义转换的 API

    v0.4.1 260 #transform #cassandra #connection #redis #kafka #topology #defines

  19. madsim-rdkafka

    madsim 上的 rdkafka 模拟器

    v0.4.2+0.34.0 2.6K #kafka #rdkafka #simulator #commit-message #async #oauth-token

  20. konsumer_offsets

    解析 Kafka 内部主题 __consumer_offsets 的内容

    v0.3.2 #apache-kafka #kafka #parser #apache #consumer-offsets #thread-safe #send-sync

  21. kafka-threadpool

    一个用于使用 SSL (mTLS) 或 PLAINTEXT 协议将消息发布到 Kafka 的异步 Rust 线程池

    v1.0.12 #kafka #thread-pool #plain-text #mtls #ssl #publishing #messages

  22. kafcat

    具有 Kafka 功能的 cat 工具

    v0.1.3 #kafka #二进制数据 #JSON 格式 #主题 #异步 #kafkacat #服务器

  23. rsprobe

    基于 Kafka 和 GStreamer 的 MpegTS 流分析探测工具

    v0.7.8 300 #gstreamer #MpegTS #kafka #pcap #广播 #网络

  24. ene_kafka

    Ene Kafka 是一个易于使用的 Apache Kafka Rust 客户端

    v0.1.0 140 #kafka #Apache Kafka #微服务 #发布/订阅 #ene-rs

  25. redpanda-transform-sdk

    Redpanda 数据转换的编写工具

    v1.1.0 110 #redpanda #kafka #数据流 #WASM #数据转换

  26. high-level-kafka

    Rust 的高级 Kafka 客户端

    v0.2.4 #kafka #高级 #rdkafka #客户端 #异步 #消息解析器 #生产者-消费者

  27. testcontainers-redpanda-rs

    非官方 redpanda 测试容器

    v0.7.2 500 #测试容器 #集成测试 #kafka #测试 #redpanda #testcontainer

  28. kafka-rs

    基于 kafka-protocol-rs 和 Tokio 的原生 Rust Kafka 客户端

    v0.5.0 #kafka #流式传输 #消息队列 #异步 #tokio #API 绑定

  29. redpanda-transform-sdk-varint

    为 redpanda-transform-sdk 提供 Varint 解码

    v1.1.0 180 #kafka #redpanda #WASM #数据转换

  30. sea-streamer-socket

    🌊 SeaStreamer 无后端 Socket API

    v0.5.0 2.2K #流处理 #异步流 #流 #kafka #异步 #数据流 #后端

  31. mlua-kafka

    mlua 的 lua-kafka 的 Rust 原生实现

    v0.1.5 170 #kafka #lua #mlua #集成 #lua-kafka #lua-jit #Rust 原生

  32. redpanda-transform-sdk-sr

    Redpanda 数据转换的 Schema Registry 客户端

    v1.1.0 120 #redpanda #kafka #WASM #数据转换 #WASM 接口

  33. mlua-rdkafka

    rdkafka 的 Lua 绑定

    v0.1.2 230 #lua 绑定 #lua #kafka #API 绑定

  34. mlua-samsa

    Samsa kafka 客户端的 Lua 绑定

    v0.1.2 350 #lua-bindings #lua #kafka #api-bindings

  35. rstreams

    具有actor模型风格的异步流处理工具包

    v0.1.0 #actor-model #streaming #kafka #redpanda #confluent

  36. streamgen

    生成数据流以供测试和基准测试

    v0.1.0 #data-stream #fake-data #data #data-streaming #kafka #generator #streaming

  37. aws-msk-iam-sasl-signer

    AWS MSK IAM SASL签名者

    v1.0.0 2.1K #iam #sasl #kafka #aws #msk

  38. rskafka_wasi

    Apache Kafka 的最小 Rust 客户端

    v0.3.1 #apache-kafka #kafka #wasi #protocols #async #api #api-bindings

  39. sea-streamer-kafka

    🌊 SeaStreamer Kafka / Redpanda 后端

    v0.5.0 2.2K #kafka #stream-processing #async-stream #stream #async #apache-kafka

  40. crab-kafka

    将 + TLS流量转发到kafka

    v0.0.5 120 #tcp-udp #kafka #tls #udp #tcp

  41. rdkafka-wrap

    rdkafka wrap

    v0.1.12 #kafka #rdkafka #producer-consumer #kafka-wrap #kafka-cli #api-bindings

  42. redpanda-transform-sdk-sys

    Redpanda 代理的 ABI 合同，用于 redpanda-transform-sdk

    v1.1.0 120 #kafka #redpanda #data-transform #wasm

  43. rumqttlog

    受kafka启发的rumqtt的mqtt提交日志

    v0.9.0 200 #mqtt #iot #kafka #distributed #nats

  44. redpanda-transform-sdk-types

    redpanda-transform-sdk的类型

    v1.1.0 130 #kafka #redpanda #data-transform #wasm

  45. kafka-to-worterbuch

    将kafka主题导出到Wörterbuch

    v1.1.4 #kafka #state #store #connector #worterbuch

  46. swimos_client

    SwimOS 客户端

    v0.1.0 #swim-os #client #real-time #stateful #streaming #kafka #self-contained

  47. swimos_algebra

    SwimOS 代数特性

    v0.1.0 #swim-os #decentralized-applications #distributed-systems #actor-model #algebraic #traits #kafka

  48. streambed-logged

    Logged 是一个小型库，它实现了一个基于文件系统的提交日志

    v0.11.0 310 #log #commit #logged #applications #events #kafka #networking

  49. ruhvro

    快速、多线程的 schema-less Avro 编码消息反序列化

    v0.2.0 #avro #arrow #kafka

  50. rusoto_kafka

    Rust 的 AWS SDK - Kafka 的托管流服务 @ 2018-11-14

    v0.48.0 #kafka #amazon #aws #rusoto-aws

  51. kofr

    用于管理 Kafka connect 集群的现代化和可配置的 CLI

    v0.1.1 #kafka #cli #kafka-connect

  52. tiny_kafka

    一个轻量级的 Kafka 客户端库，具有生产者和消费者功能

    v1.0.4 #producer-consumer #kafka #producer #consumer #streaming #rust-client

  53. qm-kafka

    Kafka 辅助函数

    v0.0.25 700 #kafka #microservices #helper #quick #functions

  54. redpanda-transform-sdk-sr-types

    redpanda-transform-sdk-sr 的类型

    v1.1.0 140 #kafka #redpanda #data-transform #wasm

  55. redpanda-transform-sdk-sr-sys

    Redpanda Schema Registry ABI 合同，用于 redpanda-transform-sdk-sr

    v1.1.0 130 #redpanda #kafka #data-transform #wasm

  56. chafka

    从 Kafka 到 ClickHouse 的实时数据摄取的可扩展服务

    v0.2.1 #clickhouse #kafka #data #service #real-time #extensible #table

  57. simple-kafka

    更易于使用的 Kafka 消息

    v0.0.8 #kafka #producer-consumer #message #topic #broker

  58. franz

    [WIP] Apache Kafka 的小型、友好的简单替代品

    v0.1.0 #kafka #ring-buffer #apache-kafka #queue

  59. stream_delimit

    长度分隔的 protobuf 流分隔符

    v0.5.6 200 #protobuf #stream #serde #length #delimited #kafka #varint

  60. kafka-replicator

    在 Kafka 集群之间复制数据的应用程序

    v0.5.1 #kafka #replication #apache-kafka #observer #event-streaming

  61. kjp_generator

    自定义 Kafka JSON 处理器生成器，kafka-json-processor 项目的部分

    v0.1.2 #kafka #generator #json #processor #config-file #topic #generate

  62. talos_rdkafka_utils

    Talos 中使用的 RD Kafka 工具

    v0.2.15 600 #kafka #utilities #talos #rd

  63. yrs-kafka

    使用RocksDB和Kafka实现Yrs同步和持久化

    v0.1.0 #kafka #persistence #yrs #crdt #rocksdb

  64. rust-with-kafka-tls

    使用自签名TLS资产加密的Strimzi Kafka集群，采用mTLS进行客户端认证的Rust消息传递

    v1.0.6 #tls-client #tls #kafka #mtls #messaging #encryption #tls-server

  65. dink

    使用Rust编写的线程化CDC到Delta lake，正如上帝所期望的那样

    v0.1.0 #delta-lake #cdc #kafka #change-data-capture #data-engineering

  66. kafka_json_processor_core

    您Kafka处理器的核心逻辑，是kafka-json-processor项目的一部分

    v0.1.2 #kafka #json #error #processor #stream #topic #definition

  67. talos_messenger_actions

    Talos的消息操作

    v0.2.15 390 #messenger #talos #actions #kafka #publishing #on-commit

  68. rlink-connector-kafka

    高性能流处理框架

    v0.6.6 #stream-processing #kafka #stream #flink #window

    69. 尝试使用DuckDuckGo进行搜索。[搜索]

  69. segments

    受kafka启发的rumqtt的mqtt提交日志

    v0.3.0 370 #kafka #segment #commitlog #disk #in-memory #mqtt

  70. mz_rusoto_kafka

    Rust 的 AWS SDK - Kafka 的托管流服务 @ 2018-11-14

    v0.46.0 #kafka #amazon #aws #aws-sdk #rusoto-aws

  71. krs

    Kafka命令行工具

    v0.2.4 #kafka #producer #consumer #rdkafka #command-line-tool

  72. kafka-totop

    TUI绘图Kafka消息输入速率

    v0.2.1 #kafka #tui #message #topic #monitoring #rates #input

  73. cloudevents-sdk-rdkafka

    CloudEvents官方Rust SDK - Kafka集成

    v0.3.1 #cloud-events #sdk #integration #kafka #rdkafka #look

  74. streambed-kafka

    提交日志功能，用于连接Kafka HTTP API

    v0.11.0 310 #kafka #commit #log #connect #http-api #topic #events

  75. kafka-serde

    用于Kafka协议的序列化和反序列化

    v0.1.0 #kafka #serde #derive-deserialize #database-interfaces #io-write

  76. kafka-offsets-parser

    解析 __consumer_offsets 主题上的偏移量消息和键的解析器

    v0.1.2 300 #offset #message-parser #topic #kafka #key #consumer-offsets

  77. xorc-notifications

    从 Kafka 发送推送通知的消费者

    v0.1.0 #consumer #kafka #web-push #fcm #apns

  78. plumber-kafka

    易于使用的 Kafka 命令行界面

    v0.1.0 #pipeline #kafka #pipe #cli #cli-tool #plumber

  79. librdkafka-sys

    librdkafka 库的原生绑定

    v0.9.2-0 #kafka #rdkafka #librdkafka #asynchronous #client #future #native

  80. kjp_generator_plugin

    作为 kafka-json-processor 项目一部分的 kjp-generator 自定义代码生成器的基础

    v0.1.1 #error #plugin #generator #kafka #json #processor #utilities

  81. br-kafka

    kafka 队列

    v0.0.2 #kafka #queue #br #carryxd

  82. df-kafka

    kafka 队列

    v0.1.3 #kafka #queue #df #carryxd #service

  83. kf-socket

    使用 Kafka 协议提供 TCP 套接字包装器

    v2.0.0 #tcp-socket #sockets #kafka #wrapper #protocols #send #request

  84. redpanda

    与 Redpanda 消息代理交互

    v0.5.0 #message-broker #kafka #redpanda-rs #api-bindings

  85. kafkaesque

    Rust 中的 Kafka 实现（非官方）

    v0.0.15 #kafka #unofficial #client

  86. brod

    提供并行执行 Kafka 生产者的 API 的包装库

    v0.1.3 #producer #kafka #parallel #tokio #send-message

  87. ene_kafka_derive

    用于 Ene Kafka 的派生宏

    v0.1.0 130 #kafka #microservices #pub-sub #ene-kafka #ene-rs #deserialize #debugging

  88. janus-kafka

    Janus 的 Kafka 后端

    v0.4.1 #janus #kafka #back-end #message

  89. kafka-topic-analyzer

    Apache Kafka 主题内容指标的获取分析器

    v0.4.0 #kafka #apache-kafka #cli #topic #metrics #analyzer #getting

  90. tower-kafka

    Apache Kafka 的 Tower 服务

    v0.0.2 #apache-kafka #tower-service #kafka #tower #tokio

  91. pipekafka

    基于 rdkafka 的 pipebase 插件

    v0.2.3 #pipebase #rdkafka #kafka #pipeware

  92. solana-accountsdb-plugin-kafka

    Solana AccountsDb 的 Kafka 插件

    v0.1.4+solana.1.11.3 180 #kafka #plugin #solana #publisher #accounts-db #ms #config

  93. r-harvest

    Kafka 和 Postgres 的事务性 Outbox 实现

    v0.2.4 #kafka #transaction #outbox

  94. rafka

    纯 Rust Kafka 客户端

    v0.1.0 #kafka #client #rafka

  95. rdkafka-cli

    与 Kafka 交互的命令行工具

    v0.1.0 #kafka #tool #cli #line #command #command-line-tool

  96. kafgrind

    kafka 的基准测试 crate

    v0.1.0 #benchmarking #kafka #kafgrind

  97. kf-protocol

    Kafka 协议的本地 Rust 实现

    v3.0.0 #protocols #kafka #native #api-bindings