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

搜索资源列表

  1. example-kafka-源码

  2. Apache Kafka的资料库 Linux上的Apache Kafka固件和虚拟机的基本原理（适用于docker或projeto的futuramenteseráincluido um）

  3. 所属分类：其它

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

  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
    • 文件大小：134kb
    • 提供者：weixin_42113456

  1. axonrpc:Axon RPC-与gRPC一样使用axon，但通过消息传递（nat，pulsar，kafka等）-源码

  2. 轴突RPC RPC over事件流。 使用Axon RPC，我们可以在事件流上执行类似gRPC的RPC调用。 它使用github.com/Just4Ease/axon作为连接流，同时帮助我们为RPC调用提供类型化的函数签名。 AxonRPC还与代码生成器捆绑在一起，其中用于生成go代码和gRPC处理程序的同一个protobuf用于生成go代码和axonRPC处理程序，与go中的gRPC完全相同，因此不会有太多的知识差距。 如何使用 # install protoc plugin: go

  3. 所属分类：其它

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

  1. go-opentracing-example-源码

  2. go-opentracing-example 使用作为跟踪器的端到端go 示例。 本示例说明如何利用开放式跟踪来查看涵盖以下流程的跨度： 如你看到的： 通过对HTTP http-sever-initiator执行HTTP请求来启动跨度，该http-sever-initiator依次通过HTTP调用http-sever-receiver 注册子跨度后， http-sever-receiver通过GRPC调用grpc-server grpc-server将消息发布到kafka中，并在注册

  3. 所属分类：其它

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

  1. Myproject：GoAPIData处理-源码

  2. 数据处理项目（Go / Golang） Go Application结合了API服务，Apache Kafka和Elasticsearch，可处理新闻同步和新闻检索。 技术领域 Go / Golang || HTTP服务|| Apche Kafka || Redis || Elasticsearch || Linux Craft.io图 第一步：数据访问与统一 1将不同的开放新闻源与API服务连接。 2将数据标准化为统一格式。 3从Apache Kafka馈送数据并将其向下游推送。 Ope

  3. 所属分类：其它

  1. confluent-kafka-go-producer-example：基于Confluent的Kafka Go库的Kafka生产者示例-源码

  2. 概述 本存储库包含Kafka生产者的示例性实现。 该实现基于Confluent Kafka Go库和Confluent的示例实现的略微扩展，可以在找到。 用法 要构建Kafka生产者，只需执行以下命令： $ make 确保之前已安装。 可以使用以下命令运行示例应用程序： confluent-kafka-go-producer-example-amd64 -c config.yaml process

  3. 所属分类：其它

    • 发布日期：2021-02-14
    • 文件大小：12kb
    • 提供者：weixin_42099936

  1. kafka_confluent-源码

  2. 命令：通过运行启动Confluent平台 $ docker-compose up -d 创建一个主题： $ docker-compose exec broker kafka-topics --create --topic example-topic --bootstrap-server broker：9092 --replication-factor 1 --partitions 1 启动控制台使用者： $ docker-compose exec broker bash $ kafka

  3. 所属分类：其它

  1. kafka-example-with-java：Apache Kafka com Java实用程序解决方案-源码

  2. Apache Kafka com Java实用程序示例 解决方案是使用Apache Kafka COM 01代理的实用程序。 爆米花 kafka-topics --bootstrap-server localhost：9092 --topic --create --partitions 3 --replication-factor 1 残酷的参与者 kafka-topics --alter --bootstrap-server localhost：9092 --topic --partiti

  3. 所属分类：其它

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

  1. 字数-源码

  2. 跑步 需要docker ./start.sh 您可以在example-curl.sh中查看示例HTTP请求 快速概述 使用node.js流读取数据。 尝试以易于更改持久性层或处理流逻辑的方式来构造代码。 使用MySQL-从流中读取单词时，我们每保存大约1000个单词左右。 字数统计是通过异步方式完成的，您提交请求，然后获得jobId。 然后，您可以稍后检查jobId以查看是否成功。 说明/决定： 这个设计的问题 用户必须忙于等待其工作成功或失败而获得通知，可以通过使用诸如AWS SNS，kaf

  3. 所属分类：其它

    • 发布日期：2021-02-12
    • 文件大小：103kb
    • 提供者：weixin_42162216

  1. kafka-images：Apache Kafka的融合Docker映像-源码

  2. Kafka的Docker映像 此仓库提供了 Docker映像的构建文件。 物产 属性是从顶级POM继承的。 可以在命令行（ -Ddocker.registry=testing.example.com:8080/ ）或子项目的POM中覆盖属性。 docker.skip-build ：（可选）设置为false以将Docker映像作为构建的一部分包括在内。 默认值为“ false”。 docker.skip-test ：（可选）设置为false以将Docker映像集成测试作为构建的一部分包括在内。

  3. 所属分类：其它

    • 发布日期：2021-02-11
    • 文件大小：163kb
    • 提供者：weixin_42127020

  1. kafka-nodejs-example：使用Kafka和NodeJS中的生产者和消费者的展示-源码

  2. Kafka NodeJS示例 介绍 该存储库展示了将Kafka与NodeJS结合使用的示例。 在此示例中，我们将Kafka用作消息传递系统，以将假设的销售量插入数据库中。 它不是将我们的销售端点直接打入数据库，而是将销售数据推送到Kafka，从而充当“生产者”。 我们启动了一个“消费者”，它将从Kafka中获取数据并将其推入数据库。 使用说明 本演示假定您已经安装了docker和docker-compose 。 步骤如下： 使用docker-compose ，启动所有容器（Zookeeper

  3. 所属分类：其它

  1. kafka-spring-boot-example：Spring Boot应用程序显示与Kafka一起使用的基本配置-源码

  2. Spring Boot Kafka示例-实际开发人员 基本配置 该示例应用程序演示如何使用基本的Spring Boot配置将生产者设置为具有多个分区的主题以及具有三个不同使用者的使用者组。 完整的解释在The Practical Developer网站上： 。 多种序列化/反序列化格式 为了说明不同的配置选项，此应用程序以三种不同的方式反序列化Kafka消息： 作为JSON到Java对象。 作为简单的String（纯JSON）。 作为字节数组。 Docker撰写 该代码包含docker

  3. 所属分类：其它

    • 发布日期：2021-01-30
    • 文件大小：72kb
    • 提供者：weixin_42128315

  1. microservice-scaffold：基于Spring Cloud（Greenwich.SR2）构建的微服务脚手架（适用于在线系统），已集成注册中心（Nacos Config），配置中心（Nacos Discovery），认证授权（O

  2. 微服务支架 基于Spring Cloud（Greenwich.SR2）构建的微服务脚手架，已集成注册中心（Nacos Config），配置中心（Nacos Discovery），认证授权（Oauth 2 + JWT），日志处理（ELK + Kafka），限流熔断（AliBaba Sentinel），应用指标监控（Prometheus + Grafana），调用链监控（Pinpoint），以及Spring Boot Admin。 快速开始 依赖环境： 启动 基础环境建设 纳科斯 当前应用配置文件在

  3. 所属分类：其它

  1. rust-kafka-consumer-example-源码

  2. rust-kafka-consumer-example

  3. 所属分类：其它

    • 发布日期：2021-04-01
    • 文件大小：11kb
    • 提供者：weixin_42132056

  1. connector-backend-example-源码

  2. 自述文件 安装Protobuf 如果您希望将.proto定义编译为ruby，则需要从您最喜欢的包管理器或源代码中安装。 该gem当前支持高达3.6.x的protobuf。 注意：编译的标头不是该库起作用的运行时要求，仅当您希望将定义编译为ruby时才需要。 OSX安装 $ brew install protobuf 的Ubuntu $ sudo apt-get install -y protobuf 安装卡夫卡 OSX安装 $ brew cask install java $ brew i

  3. 所属分类：其它

    • 发布日期：2021-03-30
    • 文件大小：220kb
    • 提供者：weixin_42178963