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

搜索资源列表

  1. kafkajiaocheng.zip

  2. Kafka最初是由LinkedIn公司开发的消息系统，现在已成为Apache的开源项目。早期版本的Kafka主要是作为一个分布式、可分区和具有副本的消息系统，随着版本的不断迭代，在0.10.x版本之后Kafka已成为一个分布式流数据处理平台，特别是KafkaStreams的出现，使得Kafka对流数据处理变得更加简单。

  3. 所属分类：Java

    • 发布日期：2019-06-09
    • 文件大小：162529280
    • 提供者：w5619994

  1. Kafka Streams 实战 - 源码.zip

  2. Kafka Streams是Kafka提供的一个用于构建流式处理程序的Java库，它与Storm、Spark等流式处理框架不同，是一个仅依赖于Kafka的Java库，而不是一个流式处理框架。除Kafka之外，Kafka Streams不需要额外的流式处理集群，提供了轻量级、易用的流式处理API。

  3. 所属分类：kafka

    • 发布日期：2019-06-30
    • 文件大小：46137344
    • 提供者：qiaorh11

  1. Spring Cloud_Greenwich.RELEASE

  2. Spring Cloud_Greenwich.RELEASE，本文是英文文档。Spring Cloud provides tools for developers to quickly build some of the common patterns in distributed systems (e.g. configuration management, service discovery, circuit breakers, intelligent routing, micro-prox

  3. 所属分类：Java

    • 发布日期：2019-03-16
    • 文件大小：7340032
    • 提供者：zhao_sh

  1. kafka-streams-dashboards:监控Kafka Streams应用程序的仪表板的演示-源码

  2. Kafka Streams仪表盘 展示对Kafka Streams指标的监视 这是代码和仪表板，是名为“ 2021年卡夫卡欧洲峰会演讲的基础 。 TL; TR 设置和配置全部在./scr ipts/startup.sh脚本中； 从根目录执行以使所有内容运行。 格拉法纳仪表板 https://localhost:3000 证书： 用户名： admin 密码： grafana 例子 Kafka Streams线程仪表板 码头工人 该项目利用docker和docker compose进行演

  3. 所属分类：其它

    • 发布日期：2021-03-15
    • 文件大小：3145728
    • 提供者：weixin_42161497

  1. alarms-filter:Kafka Streams应用程序可过滤JAWS中的活动警报-源码

  2. 警报过滤器 应用程序可将活动警报过滤到单独主题中。 这个程序提供了通过设计抑制警报的功能。 例如，当由于部分机器关闭而需要禁用一组警报时。 Alarms-Filter应用程序监视命令主题以创建和维护一组过滤的输出主题（使用紧凑清理策略）。 每个活动警报主题的使用者都可以始终创建自己的本地过滤器，但是alarms-filter应用程序为所有使用者提供了一组共享的已过滤主题的全局集合。 快速撰写 抢项目 git clone https://github.com/JeffersonLab/alarm

  3. 所属分类：其它

    • 发布日期：2021-03-09
    • 文件大小：88064
    • 提供者：weixin_42117032

  1. Kafka-Pipeline：该项目旨在探索Kafka。 我创建了一个Twitter生产者，一个ElasticSearch消费者，并在一定程度上探讨了Kafka Streams-源码

  2. 在这个项目的帮助下，我能够探索卡夫卡的生产者，消费者和流的概念。 工作流用Java编写，用于从Twitter轮询数据并将数据转储到AWS ElasticSearch。

  3. 所属分类：其它

    • 发布日期：2021-02-17
    • 文件大小：33792
    • 提供者：weixin_42136365

  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. 学习kafkastreams-源码

  2. 学习kafkastreams

  3. 所属分类：其它

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

  1. twitterstream：Scala中带有Kafka Streams的Twitter Streaming API示例-源码

  2. twitterstream：Scala中带有Kafka Streams的Twitter Streaming API示例

  3. 所属分类：其它

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

  1. kafka-streams-query：库在Kafka Streams交互式查询之上提供基于http的查询-源码

  2. kafka-streams-query：库在Kafka Streams交互式查询之上提供基于http的查询

  3. 所属分类：其它

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

  1. kafka-streams：等同于nodejs的kafka-streams-源码

  2. 节点卡夫卡流 // suggested Node.js version: v12.16.1 npm install --save kafka-streams const { KafkaStreams } = require ( "kafka-streams" ) ; const config = require ( "./config.json" ) ; const factory = new KafkaStreams ( config ) ; const kstream = factory

  3. 所属分类：其它

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

  1. stream-reactor：具有Kafka和Kafka-Connect的ETL的流参考架构。 您可以在http://lenses.io上找到更多信息，以了解我们如何提供统一的解决方案来管理连接器，用于Kafka和Kafka Streams

  2. 随便加入我们 Apache Kafka镜头 Lenses提供SQL（用于数据浏览和Kafka流），Kafka Connect连接器管理，集群监视等。 您可以在上找到更多 流React器 用于构建实时摄取管道的组件的集合。 Kafka兼容性 Kafka 2.5+（汇合5.5）-物流React器2.0.0+ Kafka 2.0-> 2.4（汇合5.4）-流式React器1.2.7 连接器 请花一点时间阅读文档，并确保满足软件前提条件！！ 连接器 类型 描述 文件 AWS S3 水槽

  3. 所属分类：其它

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

  1. clojure-kafka-examples：Kafka和Kafka Streams的Clojure示例（JAVA Interop）-源码

  2. 关于 使用带有Clojure的Kafka和Kafka流的示例示例。 我想通过Clojure而不是Clojure包装器来学习真正的Kafka API，因此这里是使用原始API的示例，它很干净，意味着您无需等待Clojure包装器库来升级Kafka。 有关示例的指南，请参见。 先决条件 期望能够设置Zookeeper和Kafka Broker来运行示例。 或使用Confluent平台。 Kafka Stream示例都具有相关的测试，而不是运行Jar。 请检查各个模块自述文件以检查其运行方式。 单元

  3. 所属分类：其它

    • 发布日期：2021-02-02
    • 文件大小：54272
    • 提供者：weixin_42141437

  1. kafka-streams-clojure：Clojure换能器与Kafka Streams的接口-源码

  2. kafka-streams-clojure：Clojure换能器与Kafka Streams的接口

  3. 所属分类：其它

    • 发布日期：2021-01-31
    • 文件大小：11264
    • 提供者：weixin_42144707

  1. springboot-kafka-connect-jdbc-streams：主要目标是使用Kafka Connect和Streams。 我们有store-api，可在MySQL中插入更新记录； 源连接器监视MySQL中插入的更新记录，并将与

  2. springboot-kafka-connect-jdbc-streams 该项目的主要目标是与 ， 和一起玩。 为此，我们具有：在中插入/更新记录的store-api ； Source Connectors ，用于监视MySQL插入/更新的记录，并将与这些更改相关的消息推送到Kafka ； Sink Connectors ，用于监听来自Kafka消息并在插入/更新文档； 最后， store-streams会监听来自Kafka消息，使用Kafka Streams对待它们，然后将新消息推回到Ka

  3. 所属分类：其它

    • 发布日期：2021-01-30
    • 文件大小：1048576
    • 提供者：weixin_42138139