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

搜索资源列表

  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. Kafka源码系列教程之删除topic

  2. 主要给大家介绍了关于Kafka源码系列教程之删除topic的相关资料，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧

  3. 所属分类：其它

    • 发布日期：2020-08-27
    • 文件大小：85kb
    • 提供者：weixin_38556822

  1. yl-hbase-rep:hbaseplicationsnapshot实现机制，源码解析，以及复制对等体的实现-源码解析

  2. yl-hbase-rep hbase快照，复制实现机制，源码解析 复制对等方的实现代码 批量加载代码示例 1个快照/复制实现机制 快照实现机制，快照文件生成过程，请参考快照内容 复制实现机制，源码解析，请参考 2复制对等体的实现 参考lily二级索引的实现机制，重新实现了一个简化版本的复制对等体 复制对等服务器从源hbase同步同步接收WAL编辑，并写入目标存储（例如：solr / kafka等） 最初的复制对等节点某个区域服务器角色 3 bulkload示例 bulkload方式从hive

  3. 所属分类：其它

  1. abora01-realtime-tracking-using-kafka-源码

  2. 这是一个有关应用kafka消息的小项目，使用开源Javascr ipt库和flask实时可视化。从geojson.io收集的地理数据标记了保存在文件中的坐标，以使用kakfka主题进行流式处理。在此示例中展示了地图的可视化访问坐标。 需要的东西上手阿帕奇卡夫卡- ，巨蟒 使用快速入门指南页面安装kafka broker，zookeeper。如果您在localhost上运行，请确保检查kafka config中的服务器属性文件。使用代理和Zookeeper的默认端口号。 在端口2181上的909

  3. 所属分类：其它

  1. golang-azure-eventhub-kafka:与Azure Event Hub连接为Kafka主题的示例-源码

  2. golang-azure-eventhub-kafka:与Azure Event Hub连接为Kafka主题的示例

  3. 所属分类：其它

  1. KafkaTestTask-源码

  2. 卡夫卡作业 该存储库包含Kafka作业的项目模板和基础结构。 任务描述 Kafka集群包含2个主题： users和notifications 。 users主题不断填充测试数据。数据格式为JSON，示例消息为： { " registertime " : 1502427342644 , " userid " : " User_5 " , " regionid " : " Region_4 " , " gender " : " FEMALE " } 应该做什么 在./WelcomeService目

  3. 所属分类：其它

  1. kafka-connect-custom-avro-converter-源码

  2. Kafka Connect Converter序列化自定义Avro模式 有关如何添加到连接器的示例： "value.converter": "com.github.noelyahan.kafka.connect.converter.AvroConverter", "value.converter.schema.registry.url": "http://localhost:8081", "value.converter.schema.subject": "com.domain.events.

  3. 所属分类：其它

  1. gohangout-output-cls-源码

  2. gohangout-output-cls 此包为项目的CLS（腾讯云日志服务腾讯云日志服务）输出插件。 特色 使用这个仓库来作为输出 去做 TLS配置项的支持 完毕 SASL已经支持 使用方法 将cls_output.go复制到gohangout主目录下面，运行 go build -buildmode=plugin -o cls_output.so cls_output.go 将cls_output.so路径作为输出 gohangout配置示例 所有参数字符串名字都使用kafka-go原生的，

  3. 所属分类：其它

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

  1. dotnet-kafka-sample:使用垂直切片体系结构的.NET Core Kafka示例应用程序-源码

  2. .NET Core Kafka示例 先决条件 码头工人 Docker撰写 怎么跑 运行以下命令以运行示例应用程序 docker-compose up

  3. 所属分类：其它

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

  1. data_engineering_task-源码

  2. 数据工程任务 数据工程任务包含Kafka和Spark示例项目。 Kafka示例项目 Kafka示例项目为Kafka应用程序开发和三个示例应用程序提供了完整的环境设置： CSV来源的数据生产者， Kafka Streams应用程序用于数据转换和 kafka使用者可以汇入PostgresDB。 可在/kafka_example文件夹中的README.md中找到启动Kafka示例项目的指南。 Spark示例项目 Spark流示例项目包含用于Spark应用程序开发的完整环境设置，以及用于网站访问量

  3. 所属分类：其它

    • 发布日期：2021-03-13
    • 文件大小：122kb
    • 提供者：weixin_42099087

  1. 工作服务：Serviçocom Kafka paraexecuçãode jobs-源码

  2. 求职服务 即时示例。 一个理想的事实，就是要在最后的工作中胜任一切。 您可以使用通用示例程序。 技术 卡夫卡; Java e Spring Boot； 码头工人; Postgres； 要求 作业的CRUD端点（Criar，Listar，Atualizar或desativar um tipo）； 终端列表作业列表状态，状态为Tipo； Jobs端点执行手册； Jobs mortos状态的终结点； 端点执行工作议程； 丰西奥门托 Deve ser cadastrado tipos de

  3. 所属分类：其它

    • 发布日期：2021-02-28
    • 文件大小：76kb
    • 提供者：weixin_42124743

  1. microservices-demo：2个通过Kafka消息代理相互通信的微服务的示例项目-源码

  2. ### Abstract这是一个示例演示项目，演示了两个微服务通过Apache Kafka消息代理以异步方式彼此通信。 这些项目包括两项服务： 用户服务 通知服务 这些服务是使用Sprint Boot和Java 11构建的。 用户服务 用户服务处理用户的批量操作： 登记 版 删除（软删除） 该服务使用内存中的H2数据库（为简单起见，因为这是一个演示项目） 通知服务 Notification-service收听Kafka主题。 当来自Kafka的消息到达时，该服务会向该消息中指定的用户发送

  3. 所属分类：其它

    • 发布日期：2021-02-25
    • 文件大小：50kb
    • 提供者：weixin_42114645

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

  1. kafka-streams-bbl-源码

  2. 丹斯·莱斯·格兰德·莱格斯计划 Kafka-streams庆子 卡夫卡101 生产者，消费者，经纪人 主题和分区 消费群体 并行模式 Qu'est-ce Qu'un流 lib Java标准 水平缩放 流处理拓扑 示例＃1-大写-JE Drive 尖峰主题管理先锋（sinon erreur audémarrage） docker exec -it kafka kafka-topics --create \ --bootstrap-server kafka:9092 \

  3. 所属分类：其它

    • 发布日期：2021-02-10
    • 文件大小：112kb
    • 提供者：weixin_42138376

  1. fluent-kafka-streams-tests：Java的Fluent Kafka Streams测试-源码

  2. 流利的Kafka Streams测试 为您的Kafka Streams应用程序编写简洁明了的测试。 您可以找到的其中包含一些示例以及Fluent Kafka Streams测试如何工作的详细说明。 入门 您可以通过Maven Central添加Fluent Kafka Streams测试。 Gradle compile group : ' com.bakdata.fluent-kafka-streams-tests ' , name : ' fluent-kafka-streams-tests

  3. 所属分类：其它

    • 发布日期：2021-02-06
    • 文件大小：165kb
    • 提供者：weixin_42099987

  1. schema-registry：适用于Kafka的Confluent Schema Registry-源码

  2. 架构注册表 Confluent Schema Registry为您的元数据提供了一个服务层。 它提供了一个RESTful接口，用于存储和检索Avro:registered:，JSON模式和Protobuf模式。 它根据指定的主题名称策略存储所有架构的版本历史记录，提供多种兼容性设置，并允许根据配置的兼容性设置以及对这些架构类型的扩展支持来演进架构。 它提供了插入到ApacheKafka:registered:客户端的序列化程序，这些客户端处理模式存储和以任何受支持的格式发送的Kafka消息的检索

  3. 所属分类：其它

  1. istio-micro：istio微服务示例代码grpc + protobuf + echo + websocket + mysql + redis + kafka + docker-compose-源码

  2. 微组织 使用go-micro建造微服务示例请到一下仓库 介绍 通过一个前后台都可以操作的用户接口，对用户服务进行操作这是一个使用服务网格（istio）生成微服务的使用示例 技术栈 技术 描述 grpc + protobuf 服务层之间的通讯 回声 应用层接口暴露 MySQL的 存储层 Redis 缓存层 卡夫卡 服务之间初步通讯 积家 双向跟踪 EFK 日志收集存储查询（没涉及，只把日志打到文件） Statik 静态文件打包 公制 监控报警（influxdb + grafana） 码头工人组

  3. 所属分类：其它

    • 发布日期：2021-02-02
    • 文件大小：461kb
    • 提供者：weixin_42120283

  1. ml-azuredatabricks：Azure Databricks的机器学习示例集合-源码

  2. 使用Azure Databricks进行机器学习 易于入门的Azure Databricks中的机器学习示例集合 ML101示例笔记本： ， 高级示例笔记本： ， Azure Databricks参考体系结构-机器学习和高级分析 主要优点： 专为企业打造，具有安全性，可靠性和可扩展性 从数据访问（ADLS，SQL DW，EventHub，Kafka等），数据准备，功能工程，在单节点或分布式中的模型构建，带有MLflow的MLop，与AzureML，Synapse和其他Azure服务集成的

  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. flink-sql在flink上运行sql和构建数据流的平台基于apache flink 1.10.0 - xianxiash / fiflow-源码

  2. 基于flink的数据流处理系统 基于 apache flink1.10 如何运行 运行 FiflowWebMain 访问 如何使用 在输入框中输入 help 给出提示信息; demo mysql : jdbc 示例 demo kafka : kafka 示例 demo elasticsearch : elasticsearch 示例 demo mysql-binlog : mysql-binlog 示例 doing 模块划分 fiflow-ui web页面

  3. 所属分类：其它

    • 发布日期：2021-01-27
    • 文件大小：10mb
    • 提供者：weixin_38685538
« 12 3 4 5 6 »