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

搜索资源列表

  1. 关于实现kafka-client客户端生产和消费消息的完整java示例项目源码下载（含依赖jar）.txt

  2. 该项目基于jdk1.8版本依赖kafka-clients-0.9.0.1.jar，实现对kafka消息订阅和产生 - 定义KafkaConsumerTest消息消费者测试类和KafkaProducerTest消息生产者测试类。

  3. 所属分类：其它

    • 发布日期：2019-07-16
    • 文件大小：172byte
    • 提供者：weixin_39841848

  1. Java天眼大型分布式跟踪系统附带源码

  2. 资源名称：Java天眼大型分布式跟踪系统 附带源码 教程内容：APP: 接入skyeye-client的系统会通过kafkaAppender向kafka写入日志es-indexer-group: kafka的es消费组，读取kafka的数据并批量bulk到esmonitor-group: kafka的监控消费组，app在日志中进行各种event埋点（如：第三方异常报警、请求耗时异常报警等）busi 资源太大，传百度网盘了，链接在附件中，有需要的同学自取。

  3. 所属分类：其它

    • 发布日期：2019-07-22
    • 文件大小：125byte
    • 提供者：weixin_39840387

  1. kafka-python 获取topic lag值方式

  2. 说真，这个问题看上去很简单，但“得益”与kafka-python神奇的文档，真的不算简单，反正我是搜了半天还看了半天源码。 直接上代码吧 from kafka import SimpleClient, KafkaConsumer from kafka.common import OffsetRequestPayload, TopicPartition def get_topic_offset(brokers, topic): """ 获取一个topic的offset值的和 """

  3. 所属分类：其它

    • 发布日期：2020-12-23
    • 文件大小：35kb
    • 提供者：weixin_38583286

  1. kafka-penguin-源码

  2. 卡夫卡企鹅 插件通过快速失败来处理消息处理失败。 快速失败是一种策略，使开发人员可以立即从内部解决问题，并立即解决依赖于Kafka的不同微服务的任何数据流问题。 WIP：该项目尚未准备好使用 用法 const allStrategies = require ( './index.ts' ) ; const testClient = require ( './clientConfig.ts' ) const failfast = allStrategies . failfastSource

  3. 所属分类：其它

    • 发布日期：2021-03-25
    • 文件大小：193kb
    • 提供者：weixin_42137032

  1. kafka_client:java kafka-client原始码精读，元分析，加阅读注释-源码

  2. kafka_client:java kafka-client原始码精读，元分析，加阅读注释

  3. 所属分类：其它

  1. go-jaeger-kafka-client:基于Golang的opentracing（或jaeger）kafka transport实现-源码

  2. go-jaeger-kafka-client:基于Golang的opentracing（或jaeger）kafka transport实现

  3. 所属分类：其它

    • 发布日期：2021-03-21
    • 文件大小：10kb
    • 提供者：weixin_42151373

  1. kafka-client-go:卡夫卡客户-源码

  2. kafka-client-go:卡夫卡客户

  3. 所属分类：其它

  1. kafka-client-源码

  2. kafka客户端

  3. 所属分类：其它

    • 发布日期：2021-03-14
    • 文件大小：11kb
    • 提供者：weixin_42131443

  1. kafka-client-rust-源码

  2. kafka-client-rust

  3. 所属分类：其它

    • 发布日期：2021-03-08
    • 文件大小：29kb
    • 提供者：weixin_42117082

  1. nestjs-kafka-demo:Nest.js + Kafka演示-源码

  2. Nest.js Kafka演示 设置 Kafka，其依赖项和Kafdrop（Kafka UI） $ docker-compose up # to start $ docker-compose down # to stop $ docker-compose down -v --rmi all # full cleanup Nest.js生产者服务 $ cd kafka-microservice-client-producer $ yarn install # install dependenci

  3. 所属分类：其它

    • 发布日期：2021-03-04
    • 文件大小：218kb
    • 提供者：weixin_42121086

  1. bootique-kafka：提供与Bootique的Kafka客户端和流的集成-源码

  2. Bootique-Kafka 为Bootique集成Kafka客户端和Kafka流。 查看用法示例： 依存关系 包括物料清单，然后包含bootique-kafka-client ： io.bootique.bom bootique-bom 2.0.M1

  3. 所属分类：其它

    • 发布日期：2021-02-18
    • 文件大小：74kb
    • 提供者：weixin_42127369

  1. 内容传输者：抓取HTML页面（由Kafka事件触发），并为Kafka主题生成选定的内容-源码

  2. 内容传送器 抓取HTML页面（由Kafka事件触发），并为Kafka主题生成选定的内容。 用法 通过纱安装 yarn install knamp-content-transmitter 然后配置并使用 import ContentTransmitter from "knamp-content-transmitter" ; ( async ( ) => { const processor = await ContentTransmitter ( { clientName : "t

  3. 所属分类：其它

    • 发布日期：2021-02-16
    • 文件大小：62kb
    • 提供者：weixin_42109545

  1. java-dcp-client：Couchbase Java DCP客户端-源码

  2. Couchbase Java DCP客户端 此存储库包含Couchbase DCP（数据库更改协议）客户端的纯基于Java的实现。 重要说明：Couchbase并未直接正式支持java-dcp-client 。 它用作更高级别（受支持）库（例如我们的kafka或elasticsearch连接器）的基本构建块。 使用风险自负！ 它支持： 低开销流 从上到下异步 流特定的vbuckets 手动开始/停止流 Noop确认和断开连接检测 流量控制 会话管理，可重启 重新平衡支持 导

  3. 所属分类：其它

    • 发布日期：2021-02-16
    • 文件大小：474kb
    • 提供者：weixin_42144366

  1. scala-kafka-client：用于运行Apache Kafka客户端库的Scala帮助器模块（0.9.x-2.1.0）-源码

  2. scala-kafka-client：用于运行Apache Kafka客户端库的Scala帮助器模块（0.9.x-2.1.0）

  3. 所属分类：其它

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

  1. NetDiscovery：NetDiscovery是一种基于Vert.x，RxJava 2等框架实现的通用爬虫框架中间件-源码

  2. 网络发现 功能特点： 轻量级爬虫 初步设计，适当扩展：支持多种消息体系（Disruptor，Redis，Kafka，RabitMQ，RocketMQ），多种网络框架（Http Client，Okhttp3，Selenium等），也支持自己实现。 支持分布式 多线程，异步化：逐步使用RxJava 2的多线程机制 支持线程池隔离：爬虫的Parser，Pipeline过程可以放在独立的线程池中进行处理 支持请求动态添加到正在运行爬虫的队列中 支持Kotlin协程 支持JS渲染 支持请求自定义heade

  3. 所属分类：其它

    • 发布日期：2021-02-03
    • 文件大小：108mb
    • 提供者：weixin_42176827

  1. XSQL：基于SparkSQL的统一SQL分析引擎-源码

  2. | XSQL是一种易于使用，运行稳定的多数据源查询引擎。1）首先，XSQL提供了一种使用标准SQL从NoSQL数据库读取数据的解决方案，因此大数据工程师可以专注于数据，而API具有特殊数据源。 2）XSQL致力于优化SQL执行的执行计划以及监视每个SQL的运行状态，从而使用户的工作运行更健康。 产品特点 XSQL现在支持八个内置数据源（例如，Hive，Mysql，EleasticSearch，Mongo，Kafka，Hbase，Redis，Druid）。 XSQL设计了一个3-layer me

  3. 所属分类：其它

    • 发布日期：2021-01-30
    • 文件大小：18mb
    • 提供者：weixin_42105570

  1. call_center_manage-源码

  2. 呼叫中心管理器Web应用程序 前端 在前端，我使用了带有样式的 。 该应用程序提供的只是一个表，该表显示特定的实时socket.io数据。 您可以在/client文件夹中运行以下命令来启动前端。 npm start 在开发模式下运行应用程序。 打开在浏览器中查看它。 npm build 构建生产到应用程序build文件夹。 它在生产模式下正确捆绑了React，并优化了构建以获得最佳性能。 后端 后端是一个 api，它创建一个socket.io Websocket来连接前端。 发送的数据来自机

  3. 所属分类：其它

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

  1. middleware-源码

  2. 中间件包括ShardingSphere分库分表的封装， Redis的封装， Kafka的封装， Elastic-Search的封装， db2es-admin的封装， db2es-client等的封装等。 sharding-starter分库分表：内置分库分表算法，SQL语法检测等功能（拦截不合法SQL，审计等功能） redis-starter：对常用的redis方法进行了封装（读写，分布式锁等功能） kafka-starter：对常用的kafka方法进行了封装（同步和异步发送，事务等功能）

  3. 所属分类：其它