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

搜索资源列表

  1. Kafka示例代码

  2. 整理的Kafka示例代码，包括集群上的生产者/消费者的Java示例代码，以及Scala编写的示例

  3. 所属分类：Java

    • 发布日期：2014-07-30
    • 文件大小：20mb
    • 提供者：f16022

  1. kafka & mafka client开发与实践

  2. Apache Kafka是分布式发布-订阅消息系统。它最初由LinkedIn公司开发，后来成为Apache项目的一部分。Kafka是一种快速、可扩展的、设计内在就是分布式的，分区的和可复制的提交日志服务。 Apache Kafka与传统消息系统相比，有以下不同： 1.它被设计为一个分布式系统，易于向外扩展。 2.它同时为发布和订阅提供高吞吐量。 3.它支持多订阅者，当失败时能自动平衡消费者；

  3. 所属分类：Java

    • 发布日期：2014-08-08
    • 文件大小：1mb
    • 提供者：lizhitao

  1. kafka & mafka client开发与实践

  2. Apache Kafka是分布式发布-订阅消息系统。它最初由LinkedIn公司开发，后来成为Apache项目的一部分。Kafka是一种快速、可扩展的、设计内在就是分布式的，分区的和可复制的提交日志服务。 Apache Kafka与传统消息系统相比，有以下不同： 1.它被设计为一个分布式系统，易于向外扩展。 2.它同时为发布和订阅提供高吞吐量。 3.它支持多订阅者，当失败时能自动平衡消费者；

  3. 所属分类：讲义

    • 发布日期：2014-11-18
    • 文件大小：1mb
    • 提供者：zhongwen7710

  1. spring-kafka-demo

  2. spring封装的kafka生产消费 ，分别针对生产者和消费者做了不同的代码测试样例

  3. 所属分类：Java

    • 发布日期：2015-09-16
    • 文件大小：169kb
    • 提供者：yeshucheng

  1. Kafka简介.ppt

  2. kafka简介架构说明 生产者消费者broker kafka使用命令 ppt

  3. 所属分类：群集服务

    • 发布日期：2015-10-13
    • 文件大小：320kb
    • 提供者：df_xiao

  1. kafka系列文档

  2. Kafka是一种高吞吐量的分布式发布订阅消息系统，它可以处理消费者规模的网站中的所有动作流数据。 这种动作（网页浏览，搜索和其他用户的行动）是在现代网络上的许多社会功能的一个关键因素。 这些数据通常是由于吞吐量的要求而通过处理日志和日志聚合来解决。 对于像Hadoop的一样的日志数据和离线分析系统，但又要求实时处理的限制，这是一个可行的解决方案。Kafka的目的是通过Hadoop的并行加载机制来统一线上和离线的消息处理，也是为了通过集群机来提供实时的消费。

  3. 所属分类：其它

    • 发布日期：2016-01-05
    • 文件大小：2mb
    • 提供者：bighai708

  1. 分布式消息系统Kafka项目-生产者消费者代码实现(基于5台虚拟机完全分布式)

  2. 消息队列 Kafka 大数据 完全分布式 Hadoop

  3. 所属分类：Java

    • 发布日期：2016-08-04
    • 文件大小：40kb
    • 提供者：nefu_yanghang

  1. 21.消息中间件之Kafka入门讲解

  2. 简单介绍了kafka的入门操作，快速搭建一个实例，以及讲解了kafka消费者组的概念

  3. 所属分类：Java

    • 发布日期：2018-06-04
    • 文件大小：12kb
    • 提供者：mrspirit

  1. 21.消息中间件之Kafka入门讲解(更新)

  2. 简单介绍了kafka的入门操作，快速搭建一个实例，以及讲解了kafka消费者组的概念

  3. 所属分类：Java

    • 发布日期：2018-06-04
    • 文件大小：76mb
    • 提供者：mrspirit

  1. Apache Flink如何管理Kafka消费者offsets

  2. Apache Flink如何管理Kafka消费者offsets

  3. 所属分类：flink

    • 发布日期：2018-12-28
    • 文件大小：241kb
    • 提供者：weixin_35761280

  1. pentaho-kafka-consumer.zip

  2. kettle kafka 消费者插件，在plugins 下新建steps文件夹，把zip文件解压放到里面。

  3. 所属分类：Java

    • 发布日期：2020-03-16
    • 文件大小：13mb
    • 提供者：u011200190

  1. kafka生产及消费示例代码，下到就是赚到

  2. kafka参考代码，一看就会，一看就懂，下到就是赚到，里面包含kafka生产及消费的实现代码，用于学习使用

  3. 所属分类：Java

    • 发布日期：2020-03-05
    • 文件大小：11mb
    • 提供者：u011294519

  1. Kafka系列2：深入理解Kafka生产者

  2. Kafka系列2：深入理解Kafka消费者 上篇聊了Kafka概况，包含了Kafka的基本概念、设计原理，以及设计核心。本篇单独聊聊Kafka的生产者，包括如下内容： 生产者是如何生产消息 如何创建生产者 发送消息到Kafka 生产者配置 分区 生产者是如何生产消息的 首先来看一下Kafka生产者组件图 第一步，Kafka 会将发送消息包装为 ProducerRecord 对象， ProducerRecord 对象包含了目标主题和要发送的内容，同时还可以指定键和分区。在发送 ProducerRe

  3. 所属分类：其它

    • 发布日期：2021-01-07
    • 文件大小：90kb
    • 提供者：weixin_38560107

  1. spring-cloud-contract-producer-kafka-consumer:Spring云合约生产商kafka消费者集成测试-源码

  2. Spring-cloud-contract-producer-kafka-consumer Spring云合约生产商kafka消费者集成测试

  3. 所属分类：其它

    • 发布日期：2021-03-22
    • 文件大小：18kb
    • 提供者：weixin_42122306

  1. Data-Ingestion-Microservice:由事件驱动的微服务，用于获取Twitter数据，这些服务使用Spring Cloud，Kafka，Prometheus，Grafana和Elastic搜索构建！-源码

  2. Twitter数据提取微服务 事件驱动的微服务，用于接收Twitter数据，这些服务使用Spring Cloud，Docker，Kafka，Prometheus，Grafana和Elasticsearch（ELK）构建！ 去做： 检索特定主题的推文流。 将数据从Java流到Kafka主题 序列化Kafka主题的流数据（每个Twitter流主题都是一个Kafka主题）。 将序列化流生成到Kafka容器中。 设置Spring Cloud Server Config。 将Kafka流写入Elastic

  3. 所属分类：其它

    • 发布日期：2021-03-18
    • 文件大小：128kb
    • 提供者：weixin_42125826

  1. 洞穴：Kafka消费者滞后检查-源码

  2. 洞穴-Kafka消费者延迟检查 Burrow是的监视伴侣，它无需指定阈值即可将消费者滞后检查作为服务提供。 它监视所有消费者的承诺抵销，并根据需要计算这些消费者的状态。 提供HTTP端点以按需请求状态，并提供其他Kafka群集信息。 还有一些可配置的通知程序，可以通过电子邮件或HTTP调用向其他服务发送状态。 特征 没有门槛！ 在滑动窗口上评估组。 多个Kafka群集支持 使用Kafka承诺的偏移量自动监视所有消费者 可配置支持Zookeeper承诺的偏移量 可配置支持Storm承诺的偏移量

  3. 所属分类：其它

    • 发布日期：2021-02-21
    • 文件大小：199kb
    • 提供者：weixin_42107561

  1. elixir-kafka-starter：使用Cowboy + Plug + Kafka_ex的示例Dockerized项目-源码

  2. ElixirKafkaStarter 使用Plug，Cowboy和Kafka_ex的示例dockerized项目。 有关如何设置Kafka消费者/生产者的文档，请参见 要快速构建并运行服务器： docker build . -t elixir-kafka-starter && docker run -it -p 8080:8080/tcp elixir-kafka-starter 服务器将位于localhost:8080 默认情况下，启动时会禁用Kafka连接。 从Kafka连接开始：

  3. 所属分类：其它

  1. aidp：weiboAd基础架构数据处理器：数据处理框架中的kafka消费者嵌入式Lua脚本语言-源码

  2. aidp：weiboAd基础架构数据处理器：数据处理框架中的kafka消费者嵌入式Lua脚本语言

  3. 所属分类：其它

    • 发布日期：2021-02-05
    • 文件大小：90kb
    • 提供者：weixin_42129300

  1. remora：用于监控的Kafka消费者滞后检查应用程序，使用Scala和Akka HTTP编写； 包装卡夫卡消费者小组命令。 与Cloudwatch和Datadog的集成。 最近添加了身份验证-源码

  2. mor 是的监视实用程序，可将使用者的滞后检查作为服务提供。 提供HTTP端点以按需请求使用者组信息。 将其与时间序列数据库（如结合使用，就可以绘制您的消费者组状态图； 有关此示例，请参见 。 Remora稳定并且可以生产。 Remora正在监视Zalando的许多生产kafka集群！ 灵感 我们花了一段时间使用Linkedin的应用程序创建了Remora，该应用程序用于监视消费者的滞后并遇到一些性能问题（在出现未知数量的错误之后没有任何错误堆栈，警报或错误迹象，因此burrow关闭了。我们

  3. 所属分类：其它

    • 发布日期：2021-02-04
    • 文件大小：36kb
    • 提供者：weixin_42120997

  1. racecar：Racecar：Ruby中针对Kafka消费者的简单框架-源码

  2. 赛车 Racecar是一个友好且易于使用的Kafka消费者框架。 它允许您编写小型应用程序，以处理存储在Kafka主题中的消息，同时可以选择与Rails模型集成。 该框架基于 ，当直接使用时，可能会遇到挑战：它是一个灵活的库，带有许多旋钮和选项。 不过，大多数用户并不需要这种灵活性。 Racecar提供了一种简单直观的方法来构建和配置Kafka用户。 注意： Racecar需要Kafka 0.10或更高。 表中的内容 安装 将此行添加到您的应用程序的Gemfile中： gem 'racec

  3. 所属分类：其它

    • 发布日期：2021-02-01
    • 文件大小：59kb
    • 提供者：weixin_42131261
« 12 3 4 5 6 7 8 9 10 ... 16 »