kafkajs：适用于node.js的现代Apache Kafka客户端

preview
共1110个文件
js：739个
json：207个
md：96个
nodejs
kafka
npm-package
kafka-client
Node.js
需积分: 20 0 下载量 146 浏览量 2021-02-04 04:18:09 上传 评论 收藏 4.51MB ZIP 举报
资源详情
资源评论
评论 收藏
新文达·小文姐姐
  • 粉丝: 29
  • 资源: 4545
上传资源 快速赚钱
voice
center-task 前往需求广场，查看用户热搜

相关推荐

zip

kafka:适用于Node的Apache Kafka 0.9客户端

诺卡夫卡 no-kafka是适用于Node.js的 0.9客户端，具有支持。 支持同步和异步Gzip和Snappy压缩，生产者批处理和可控重试，提供了一些预定义的组分配策略和生产者分区器选项。 所有方法都会返回 请检查中版本3.x的向后不兼容更改 简单的消费者简单的消费者选项 团体消费者 分配策略 团体消费者选项 组管理员 压缩 联系 SSL协议 重新映射经纪人地址 记录中 主题创作 执照
zip

node-js-kafka：使用Kafka，Node.js和Docker的基本应用程序

kafka-nodejs-教程 使用Kafka，Node.js和Docker的示例应用程序 表中的内容 1.关于Kafka流媒体 以下是Kafka官方网站的说明。 ApacheKafka:registered:是一个分布式流平台。 它发布和订阅记录流，类似于消息队列或企业消息传递系统 Kafka通常用于两大类应用程序： 建立实时流数据管道以可靠地在系统或应用程序之间获取数据构建实时流应用以转
zip

Node.js-基于kue的egg延时队列

由redis支持的优先级队列队列，为eggjs构建。
rar

kafka网上三种监控开源软件

三种工具分别是Kafka Web Conslole、Kafka Manager、KafkaOffsetMonitor
star 4星 · 用户满意度95%
zip

kafkajs:通过学术练习了解Kafka平台

卡夫卡斯 通过学术练习了解Kafka平台 我将尝试遵守以下条件： 优先使用流而不是迭代器 与Kafka保持字节兼容
zip

cppkafka:现代C ++ Apache Kafka客户端库（librdkafka的包装器）

cppkafka：高级C ++包装为rdkafka cppkafka允许C ++应用程序使用Apache Kafka协议使用和产生消息。 该库建立在，并提供了一个高级API，该API使用现代C ++功能使编写代码更容易，同时包装器的性能开销降至最低。 特征 cppkafka为rdkafka高电平C ++包装，旨在以允许使用rdkafka以简单的，不易出错的方法。 cppkafka提供了一个用于
zip

kafka-node:适用于Apache Kafka 0.8及更高版本的Node.js客户端

卡夫卡节点 Kafka-node是Apache Kafka 0.9及更高版本的Node.js客户端。 目录 抵消 行政 故障排除/常见问题解答 首次发送时出现KeyedPartitioner错误的HighLevelProducer 如何调试问题？ 对于新使用者，如何从分区中的最新消息开始使用？ ConsumerGroup不会在所有分区上使用 如何限制消息/控制消息处理的并发性 如何产生和
zip

DelphiKafkaClient:适用于Delphi的Apache Kafka客户端

DelphiKafkaClient DelphiKafkaClient是Apache 的跨平台Delphi客户端/包装器。 支持Windows（i386 / x64）和Linux（x64）。 在Delphi 10.4上进行了测试，但应与所有现代Delphi版本一起使用。 免责声明 尽管它似乎可以按预期工作，但DelphiKafkaClient是一种概念证明，从未在生产中进行过测试。 安装 您将需
zip

libkafka:适用于Apache Kafka v0.8 +的C ++客户端库。 还包括C API

利卡夫卡 适用于Apache Kafka v0.8 +的C ++客户端库。 还包括C API。 带有完整的单元测试套件。 支持以下Kafka API请求/响应调用： 元数据 生产 拿来 抵消 包括对使用GZIP或Snappy压缩的MessageSet压缩的支持。 由于线路协议的更改，因此与0.8之前的Kafka版本不兼容。 版本 当前发行版本：0.5.0（请参阅 ） 依存关系 zlib用于
zip

tokio-kafka:适用于Apache Kafka的异步Rust客户端

东京卡夫卡 该库是Rust中异步kafka客户端的实验性实现。 注意： tokio-kafka窗台处于开发阶段，公共API不稳定，尚未准备好生产。 如果您想参与该项目并为该项目做出贡献，请自担风险。 用法 首先，克隆项目并将其添加到您的Cargo.toml ： $ git clone https://github.com/flier/tokio-kafka [ dependencies ]
jar

org.apache.kafka kafka_2.10 0.10.2.0 的jar包下载

依赖方式  <groupId>org.apache.kafka  <artifactId>kafka_2.10  <version>0.10.0.0 但是没有被中央仓库的任何jar包依赖！您可以在这里点击下载
jar

org.apache.kafka kafka-clients 0.10.1.1 的jar包下载

<groupId>org.apache.kafka <artifactId>kafka-clients <version>0.10.1.1 </dependency>
star 5星 · 资源好评率100%
jar

org.apache.kafka kafka-log4j-appender 的jar包下载

<groupId>org.apache.kafka <artifactId>kafka-log4j-appender <version>0.10.2.0 </dependency>
pdf

kafka处理超大消息的配置 org.apache.kafka.common.errors.RecordTooLargeException

java.lang.RuntimeException: java.util.concurrent.ExecutionException: org.apache.kafka.common.errors.RecordTooLargeException: The request included a message larger than the max message size the server
zip

kafka-connect-client:适用于Apache Kafka Connect REST接口的Java客户端库

REST接口的Java客户端库 目录 建立项目 ./mvnw -B clean verify 程式码范例 列出所有活动的连接器 ApiClient client = Config . defaultClient(); Configuration . setDefaultApiClient(client); ConnectApi api new ConnectApi (); final
zip

pykafka:适用于Python的Apache Kafka客户端； 高水平和低水平的消费者生产者，表现出色

皮卡夫卡 PyKafka是Python的程序员友好的Kafka客户端。 它包括Kafka生产者和使用者的Python实现，可以选择由基于的C扩展支持。 它在Python 2.7 +，Python 3.4+和PyPy下运行，并支持Kafka 0.8.2和更高版本。 PyKafka的主要目标是使用Python程序员熟悉的习语为提供类似级别的抽象，并尽可能地提供最大的Pythonic API。 您
zip

kafka-rest-node:Kafka REST代理的Node.js客户端

卡夫卡休息 kafka-rest是Kafka REST代理的node.js库。 它提供了围绕REST API的精简包装，为访问群集元数据以及生成和使用Avro和二进制数据提供了更方便的接口。 注意：编写该库是为了演示如何围绕REST代理创建特定于语言的包装器。 它不再维护或保持最新（例如，现在推荐REST Proxy具有v2 API，但尚未将此包装库添加支持）。 自创建该库以来，已经开发了不需要
zip

kafka-demo:适用于Apache Kafka的简单演示Python客户端脚本

Kafka演示脚本 这是我在PyConZA 2015上有关Apache Kafka的演讲中附带的演示工具包。 它包含用于演示生产者和平衡消费者的脚本。 您可以在此处观看演讲： 依存关系 该演示需要Kafka 0.8.2。 如果您无权访问Kafka群集，则可以通过在以下位置下载来以独立模式进行设置： 并按照此处的说明进行安装： 您还将需要pykafka客户端库。 我使用的版本是2.0.0，这是
zip

brod:适用于ErlangElixir的Apache Kafka客户端库

注意 本产品包括由开发的软件 Brod-适用于Erlang / Elixir的Apache Kafka客户端 Brod是Apache Kafka协议的Erlang实现，为生产者和消费者提供支持。 为什么要“混血”？ 特征 支持Apache Kafka v0.8 + 可靠的生产者实现，支持运行中的请求和异步确认 消费者和生产者都可以在内部处理领导者连任和其他集群干扰 每个brod_client
zip

netty-kafka-101:使用Netty.io向Apache Kafka提取数据的简单演示

使用Netty采集Kafka的数据 使用Java Netty构建一个HTTP服务器，该服务器接受一个JSON对象并将其保存到Kafka队列中。 为此，请在开发机器上设置netty / kafka。 需要Java和Maven的有效安装。 基于： : Apache ...
pdf

Packt.Learning.Apache.Kafka.2nd.Edition

Chapter 1, Introducing Kafka, discusses how organizations are realizing the real value of data and evolving the mechanism of collecting and processing it. It also describes how to install and build ..
zip

finagle-kafka, 在联网和Finagle中，Apache Kafka 客户端.zip

finagle-kafka, 在联网和Finagle中，Apache Kafka 客户端 finagle-kafka联网和Finagle中的Apache Kafka 客户端。概述是 Finagle Kafka 是在网联网客户端和 Twitter的 Finagle 。 它使你能够以更功能的方式处理 Kafka...
zip

simple-kafka-node:在Node.js中使用Kafka的简单界面

在Node.js中使用Kafka的简单界面 用法 npm安装simple-kafka-node 讯息格式 { "type" :"anEventType", "data" :"A data object" } 配置 环境变量 MESSAGING_HOST: kafka host, default "locahost:2181" MESSAGING...
zip

微服务应用程序：TypeScript，Node.JS，Express，React，Redux，Next.js，MongoDB，Mongoose，事件驱动，Pub-Sub，Docker，Kubernetes，CICD，Skaffold，Apache Kafka等

微服务应用技术：TypeScript，Node.JS，Express，React，Redux，Next.js，MongoDB，Mongoose，事件驱动，Pub-Sub，Docker，Kubernetes，CI / CD，Skaffold，Apache Kafka，NATS Streaming Server等作者Aditya Hajare...
zip

storm-drpc-node:适用于Node.js的Apache Storm DRPC客户端

Storm-drpc节点 适用于Node.js的Apache Storm DRPC客户端 受启发，但不同之处在于可以选择将其设置为保持活动状态，它不需要在每个execute()调用中都创建连接，并且可以喜欢的传统方式或promise方式使用它。 安装 npm install storm-drpc-node 用法 var DRPC = require ( 'storm-drpc-node' ) ;
zip

node-zookeeper:Apache Zookeeper的node.js客户端

节点动物园管理员 概述 node-zookeeper-Apache Zookeeper的Node.js客户端。 该节点模块在官方ZooKeeper C客户端API之上实现，支持ZooKeeper服务器v3.4.x-v3.6.x。 请查看以获取有关行为的更多详细信息。 最新更改在中描述 安装 npm install zookeeper 大功告成！ （请注意小写的名字zookeeper ） 消
zip

apache-kafka-documentation-cn.zip_apache kafka_kafka

apache-kafka-documentation-cn
zip

kafka-manager-1.3.3.22.zip

已编译 Kafka-Manager-1.3.3.22 linux下直接解压解压kafka-manager-1.3.3.22.zip到/opt/module目录 [root@hadoop102 module]$ unzip kafka-manager-1.3.3.22.zip 4）进入到/opt/module/kafka-manager-1.3.3.22/...
zip

kafka-clients-0.10.0.1-API文档-中英对照版.zip

对应Maven信息：groupId：org.apache.kafka，artifactId：kafka-clients，version：0.10.0.1 使用方法：解压翻译后的API文档，用浏览器打开“index.html”文件，即可纵览文档内容。 人性化翻译，文档中的代码和结构...
star 5星 · 资源好评率100%