注册会员 | 设为首页 | 加入收藏夹
您好，欢迎光临本网站！[请登录] ！[注册会员]！  

搜索资源列表

  1. kafka-rest搭建

  2. kafka-rest搭建相关资源，包括zookeeper\kafka\rest\nginx\keepalived及nginx详细配置

  3. 所属分类：Java

    • 发布日期：2018-06-29
    • 文件大小：84992
    • 提供者：xiaoliedun7346

  1. kafka-rest, Kafka的合并REST代理.zip

  2. kafka-rest, Kafka的合并REST代理 Kafka REST代理REST REST代理为集群提供了REST式接口。 它使得生成和使用消息。查看集群状态以及在不使用本机 Kafka 协议或者客户端的情况下执行管理操作变得很容易。 用例示例包括从任何语言中构建的前端应用程序向 K

  3. 所属分类：其它

    • 发布日期：2019-09-18
    • 文件大小：382976
    • 提供者：weixin_38743602

  1. kafka-rest, Kafka的合并REST代理.zip

  2. kafka-rest, Kafka的合并REST代理 Kafka REST代理REST REST代理为集群提供了REST式接口。 它使得生成和使用消息。查看集群状态以及在不使用本机 Kafka 协议或者客户端的情况下执行管理操作变得很容易。 用例示例包括从任何语言中构建的前端应用程序向 K

  3. 所属分类：其它

    • 发布日期：2019-10-10
    • 文件大小：382976
    • 提供者：weixin_38744435

  1. kafka-study-源码

  2. -在运行之前先安装并运行Kafka。 创建kafka主题 调用rest端点将User对象发送到Kafka主题 听主题并显示数据

  3. 所属分类：其它

    • 发布日期：2021-03-18
    • 文件大小：64512
    • 提供者：weixin_42116058

  1. Chicago-Public-Transport-Kafka-源码

  2. Apache Kafka的公共交通状态 在这个项目中，您将围绕Apache Kafka及其生态系统构建一个流事件管道。 利用公开数据，我们将在卡夫卡周围构建一个事件管道，使我们能够实时模拟和显示火车线路的状态。 项目完成后，您将可以监视一个网站，以观看火车从一个车站到另一个车站的行驶。 先决条件 以下是完成此项目所需的条件： 码头工人 Python 3.7 访问至少具有16gb + RAM和4核CPU的计算机以执行仿真 描述 芝加哥运输管理局（CTA）已要求我们开发一个仪表板，以显示其通勤

  3. 所属分类：其它

    • 发布日期：2021-03-14
    • 文件大小：347136
    • 提供者：weixin_42165980

  1. kafka-connect-cdc-example-源码

  2. 使用Kafka Connect更改数据捕获的示例 该项目是使用Kafka Connect和MongoDB作为接收器SQLServer CDC的示例实现。 Kafka Connect已配置为独立模式。 （仅用于开发目的，不用于生产环境）。 使用的MSSql Server Source连接器来自Debezium（ ）。 MongoDB接收器来自MongoDB（ ）。 它是使用Docker容器和docker-compose orquestrator工具构建的。 要求 [docker-comp

  3. 所属分类：其它

    • 发布日期：2021-03-11
    • 文件大小：137216
    • 提供者：weixin_42113456

  1. 使用Akka、Kafka和ElasticSearch等构建分析引擎

  2. 在这篇文章里，我将和大家分享一下我用Scala、Akka、Play、Kafka和ElasticSearch等构建大型分布式、容错、可扩展的分析引擎的经验。我的分析引擎主要是用于文本分析的。输入有结构化的、非结构化的和半结构化的数据，我们会用分析引擎对数据进行大量处理。如下图所示为第一代架构，分析引擎可以用REST客户端或Web客户端（引擎内置）访问。简单描述一下用到的技术：Play框架做REST服务器和WEB应用。Play是个基于轻量级、无状态和WEB友好的MVC框架。Akka集群作处理引擎。A

  3. 所属分类：其它

    • 发布日期：2021-02-26
    • 文件大小：608256
    • 提供者：weixin_38595019

  1. kafka-api：Kafka的经纪人-源码

  2. Akkeris卡夫卡经纪人 纲要 运行REST API，以提供对Kafka主题，用户和ACL，架构注册表Avro到主题的映射的管理 终点 get /octhc get /v1/kafka/clusters get /v1/kafka/topics/:topic get /v1/kafka/topics get /v1/kafka/cluster/:cluster/credentials/:user get /v1/kafka/cluster/:cluster/acls get /v1/kafka

  3. 所属分类：其它

    • 发布日期：2021-02-24
    • 文件大小：68608
    • 提供者：weixin_42162171

  1. 爱马仕：基于Kafka的快速可靠的消息代理-源码

  2. 爱马仕 Hermes是建立在之上的异步消息代理。 我们为消息发布提供可靠的容错REST接口，并为消息发送提供自适应推送机制。 请参阅我们的Vagrant 10分钟入门指南： 请访问我们的页面： 请参阅我们的完整文档： : 问题？ 我们。 执照 hermes是根据。

  3. 所属分类：其它

    • 发布日期：2021-02-23
    • 文件大小：3145728
    • 提供者：weixin_42143806

  1. 使用Akka、Kafka和ElasticSearch等构建分析引擎

  2. 在这篇文章里，我将和大家分享一下我用Scala、Akka、Play、Kafka和ElasticSearch等构建大型分布式、容错、可扩展的分析引擎的经验。我的分析引擎主要是用于文本分析的。输入有结构化的、非结构化的和半结构化的数据，我们会用分析引擎对数据进行大量处理。如下图所示为第一代架构，分析引擎可以用REST客户端或Web客户端（引擎内置）访问。简单描述一下用到的技术：Play框架做REST服务器和WEB应用。Play是个基于轻量级、无状态和WEB友好的MVC框架。Akka集群作处理引擎。A

  3. 所属分类：其它

    • 发布日期：2021-02-20
    • 文件大小：608256
    • 提供者：weixin_38569722

  1. kafka-streams-interactive-queries-music-spring：这是一个使用Kafka Streams支持并带有交互式查询的Spring Cloud Stream处理器的示例。-源码

  2. 这个程序是什么？ 这是使用Kafka Streams支持的Spring Cloud Stream处理器的示例。 该示例是此Srping Cloud Streams示例的单个Maven项目的改编版： : 这是此Kafka Streams示例的Spring Cloud Stream改编版： : 该示例演示了kafka流中交互式查询的概念。 作为应用程序的一部分提供了REST服务，可用于以交互方式查询商店。 运行应用程序： 我们将运行处理器应用程序的2个实例，以演示无论哪个实例托管密钥，

  3. 所属分类：其它

    • 发布日期：2021-02-16
    • 文件大小：80896
    • 提供者：weixin_42116791

  1. zuul-kafka：PoC Netflix Zuul路由过滤器，可将REST调用转换为Kafka消息-源码

  2. PoC将REST转换为Kafka消息（请求-响应） 跑 启动卡夫卡 docker-compose up -d 启动Eureka服务器 gradle：eureka-server：bootRun 开始样品服务 gradle：sample-service：bootRun 启动Zuul网关 gradlew：zuul-gateway：bootRun 测试要求 得到 curl -d“ Sergey” -X POST 你是谁？ 要求 curl -d“ Sergey” -X POST 你好，谢尔盖

  3. 所属分类：其它

    • 发布日期：2021-02-13
    • 文件大小：75776
    • 提供者：weixin_42103128

  1. kafka-compose：Docker为各种kafka堆栈编写文件-源码

  2. Kafka Docker撰写 使用docker compose复制典型的Kafka堆栈。 跑步 export CP_STACK_VERSION=4.0.0 docker-compose up 查看主题和架构 Kafka Topics UI： Kafka Schema Registry UI： Kafka Connect用户界面： 融合的Kafka REST代理 docker-compose -f docker-compose.yml -f docker-compose.rest-prox

  3. 所属分类：其它

    • 发布日期：2021-02-06
    • 文件大小：18432
    • 提供者：weixin_42143161

  1. messenger-kafka：Symfony Messenger的简单Kafka传输-源码

  2. Symfony Messenger卡夫卡运输 该捆绑包旨在为Symfony Messenger提供简单的Kafka传输。 Kafka REST代理支持即将推出。 安装 使用Symfony Flex的应用程序 打开命令控制台，输入项目目录并执行： $ composer require koco/messenger-kafka 不使用Symfony Flex的应用程序 添加了作曲家需求之后，通过将其添加到项目的config/bundles.php文件中已注册捆绑包的列表中来启用捆绑包： ret

  3. 所属分类：其它

    • 发布日期：2021-02-06
    • 文件大小：27648
    • 提供者：weixin_42138780

  1. kafka-rest：用于Kafka的融合REST代理-源码

  2. Kafka REST代理 Kafka REST代理为Kafka集群提供了RESTful接口。 无需使用本机Kafka协议或客户端，即可轻松生成和使用消息，查看集群状态以及执行管理操作。 用例示例包括使用任何语言构建的任何前端应用程序向Kafka报告数据，将消息摄取到尚不支持Kafka的流处理框架中以及编写管理操作脚本。 安装 您可以作为一部分下载Kafka REST代理的预构建版本。 您可以阅读我们的完整和完整的 要从源代码安装，请遵循下面“开发”部分中的说明。 部署方式 REST代理包括内置

  3. 所属分类：其它

    • 发布日期：2021-02-05
    • 文件大小：669696
    • 提供者：weixin_42172572

  1. kastlex：Elixir中的Kafka REST代理-源码

  2. KastleX-Elixir中的Kafka REST代理 Kastle是Kafka集群的REST接口，由和。 另请参阅 。 开始吧 mix deps.get mix phx.server 从交互式外壳开始： iex --sname kastlex -S mix phx.server 在加载了所有应用程序路径的情况下启动交互式外壳程序，但不启动任何应用程序 iex -S mix shell 默认情况下，KastleX将尝试连接到localhost：9092上的kafka和localhost：2

  3. 所属分类：其它

    • 发布日期：2021-02-05
    • 文件大小：73728
    • 提供者：weixin_42099530

  1. 节点服务器模板：这是具有Express（带有异步处理程序，自定义错误处理程序）框架和MongoDb的Node.js服务器整洁模板样板。 服务器使用ES6及更高版本。 在不同的分支上，您可以看到不同的技术和技术的用法，例如Kafka，node

  2. Node.js服务器模板 目录 基本信息 这是具有CRUD操作简单逻辑的简单Node.js服务器应用程序样板。 它提供了REST API。 在使用它之前，请确保您已经安装了以下程序作为版本控制， 作为服务器程序， 如Node.js的包管理器， 作为数据库程序。 如果尚未安装，则这些是它们的安装链接。 技术领域 程序/库| 版本| 检查命令Git | 2.24.0 | git --version Node.js | v12.15.0 | node -v 快递| ^ 4.17.1 | 在应用程序pa

  3. 所属分类：其它

    • 发布日期：2021-02-04
    • 文件大小：543744
    • 提供者：weixin_42146888

  1. springboot-crypto-kafka-docker：为了在计算机中部署Confluent Kafka，该项目启动了4个Docker容器（ZooKeeper，Kafka，Kafka-REST-Proxy和Kafka-Topics-U

  2. springboot-crypto-kafka-docker 为了在机器中部署 ，该项目启动了四个Docker容器（ ， ， 和 ）。 它还会启动其他三个容器（一个生产者和两个消费者）来模拟使用加密货币JSON数据的消息发布/消费。 Producer和Consumers映像是使用开发的，随后使用启动了容器。 该项目使用来获取比特币，莱特币和其他加密货币的JSON数据。 脚步 1.克隆并构建项目 运行以下命令以克隆项目： git clone https://github.com/wagn

  3. 所属分类：其它

    • 发布日期：2021-02-04
    • 文件大小：376832
    • 提供者：weixin_42113754

  1. nakadi：分布式事件总线，在类似于Kafka的队列上实现RESTful API抽象-源码

  2. Nakadi是一个分布式事件总线代理，它在类似于Kafka的队列上实现RESTful API抽象，可用于以可靠且高度可用的方式实时发送，接收和分析流数据。 Nakadi最突出的用例之一是通过在生产者和消费者之间建立数据流来使微服务脱钩。 nakadi的主要用户是开发人员和分析师。 Nakadi提供的功能包括基于REST的集成，多用户，有序交付，交互式UI，完全托管，安全性，确保数据质量，大数据技术的抽象以及基于推送模型的使用。 Nakadi正在积极开发中，目前正在Zalando内部进行生产

  3. 所属分类：其它

    • 发布日期：2021-02-03
    • 文件大小：2097152
    • 提供者：weixin_42134537

  1. kafka-pixy：Kafka的gRPCREST代理-源码

  2. Kafka-Pixy（用于Kafka的gRPC / REST代理） Kafka-Pixy是具有自动使用者组控制的双重API（gRPC和REST）代理。 它旨在隐藏Kafka客户端协议的复杂性，并提供一个愚蠢的简单API，可以用任何语言轻松实现。 Kafka-Pixy已针对Kafka 1.1.1和2.3.0版本进行了测试，但可能适用于0.8.2.2以后的任何版本。 它使用Kafka 来跟踪消费者抵销。 但是， 尚未实现，因此需要直接与Zookeeper对话以管理消费者组成员身份。 警告：Ka

  3. 所属分类：其它

    • 发布日期：2021-02-03
    • 文件大小：240640
    • 提供者：weixin_42098830
« 12 3 4 »