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

搜索资源列表

  1. kafaka文档.pdf

  2. 1.入门 1.1简介 1.2用例 1.3快速入门 1.4生态系统 1.5升级 2. API 2.1生产者API 2.2消费者API 2.3 Streams API 2.4连接API 2.5 AdminClient API 2.6旧版API 3.配置 3.1经纪人配置 3.2主题配置 3.3制片人配置 3.4消费者配置 3.4.1新的消费者配置 3.4.2旧消费者配置 3.5 Kafka Connect配置 3.6 Kafka Streams配置 3

  3. 所属分类：其它

    • 发布日期：2019-06-24
    • 文件大小：1048576
    • 提供者：mickey_51

  1. 2019年SpringBoot面试专题及答案.pdf

  2. 2019年最新整理SpringBoot面试专题及答案,希望的大家互相交流!server port =8090 问题八 什么是YAML? YAML是一种人类可读的数据序列化语言。它通常用于配置文件。 与属性文件相比,如果我们想要在配置文件中添加复杂的属性,YAML文件就吏加结杓 化,而且更少混淆。可以看出YAML具有分层配置数据。 问题九 如何实现 Spring boot应用程序的安全性? 为了实现 Spring boot的安全性,我们使用 spring-boot-starter-security

  3. 所属分类：Java

    • 发布日期：2019-07-06
    • 文件大小：439296
    • 提供者：xiaofeivip_top

  1. SpringBoot面试专题及答案.pdf

  2. 什么是 Spring Boot？Spring Boot 有哪些优点？什么是 JavaConfig？如何重新加载 Spring Boot 上的更改，而无需重新启动服务器？server port =8090 问题八 什么是YAML? YAML是一种人类可读的数据序列化语言。它通常用于配置文件 与属性文件相比,如果我们想要在配置文件中添加复杂的属性,YAML文件就吏加结构 化,而且更少混淆。可以看出YAML具有分层配置数据。 问题儿 如何实现 Spring boot应用程序的安全性? 为了实现 Spr

  3. 所属分类：Java

    • 发布日期：2019-07-02
    • 文件大小：353280
    • 提供者：luck332

  1. KAFKA权限配置SASL/PLAIN身份验证

  2. zookeeper集群SASL认证&KAFKA权限配置SASL/PLAIN身份验证 配置环境 JKD: 1.8 Kafka: 2.3.0 Zookeeper: 3.4.14 服务器名 kafka内网IP:PORT kafka外网IP:PORT zookeeper内网IP:PORT KAFKA01 192.168.1.157:9092 116.155.153.185:19092 192.168.1.157:2181 KAFKA02 192.168.1.158:9092 116.

  3. 所属分类：其它

    • 发布日期：2021-01-07
    • 文件大小：108544
    • 提供者：weixin_38678172

  1. goim:goim源码阅读-源码

  2. goim v2.0 goim是golang编写的即时通讯服务器。 特征 轻的 高性能 纯净的高朗 支持单推，多推和广播 支持多个用户的一把钥匙（可配置的最大用户数） 支持心跳（应用程序心跳，TCP，KeepAlive，HTTP长拉） 支持身份验证（未经身份验证的用户无法订阅） 支持多种协议（WebSocket，TCP，HTTP） 可扩展的体系结构（无限的动态作业和逻辑模块） 基于Kafka的异步推送通知 建筑学 快速开始 建造 make build 跑 make ru

  3. 所属分类：其它

    • 发布日期：2021-03-23
    • 文件大小：4194304
    • 提供者：weixin_42138788

  1. GrubHub-Clone:使用Node.js和React.js克隆食品交付应用程序（GrubHub）-源码

  2. 送餐应用 Gradaute软件工程课程“企业分布式系统”的单个项目。 目标 目标是建立一个分布式企业Web应用程序，该应用程序允许用户在线订购食物。 系统中有2个参与者： 餐馆老板-可以添加新餐馆，菜单项，更改订单状态。 客户-可以搜索不同的餐厅，菜肴，下订单并查看订单状态。 我们承担了这个项目要求的任务，以便我们可以学习使用各种分布式技术（例如，将Apache Kafka作为消息队列，将Redis用于缓存等）来构建企业MERN堆栈应用程序。 系统设计 技术栈 区域 技术 前端 Reac

  3. 所属分类：其它

    • 发布日期：2021-03-14
    • 文件大小：618496
    • 提供者：weixin_42117224

  1. Tombolo-源码

  2. Tombolo-用于HPCC系统的数据整理工具 安装： 克隆Git回购 将.env.sample重命名为.env 更新.env中的以下信息 DB_USERNAME DB_PASSWORD 秘密-使用来自的字母数字值作为此秘密。 AUTH_SERVICE_URL-Tombolo使用身份验证服务进行用户身份验证。 可以使用现有的身份验证服务，也可以为此单独设置身份验证服务。 有关设置的详细信息，请参阅Auth Service存储库。 应用程序将在其上侦听的WEB_PORT和WEB_EXP

  3. 所属分类：其它

    • 发布日期：2021-03-11
    • 文件大小：2097152
    • 提供者：weixin_42101056

  1. GetOffsetShell_kafka_SSL:具有SSL的kafka.tools.GetOffsetShell-源码

  2. GetOffsetShell_kafka_SSL 在具有SSL的kafka kafka.tools.GetOffsetShell中启用SSL身份验证时，GetOffsetShell的解决方案不起作用

  3. 所属分类：其它

    • 发布日期：2021-03-11
    • 文件大小：2048
    • 提供者：weixin_42136365

  1. vscode-kafka:用于Visual Studio Code的kafka扩展-源码

  2. 用于Visual Studio Code的Kafka扩展 直接在Visual Studio Code中使用Kafka。 支持运行0.11或更高版本的Kafka集群。 特征： 连接到多个集群 查看集群中的代理 查看主题 查看配置 创建/删除主题 产生（随机）消息 消费信息 SASL / PLAIN，SASL / SCRAM-256，SASL / SCRAM-512身份验证（Kafka 0.10+） 计划中的功能没有特定的顺序： 更多管理功能 使vscode-kafka可扩展 改善消费者D

  3. 所属分类：其它

    • 发布日期：2021-03-10
    • 文件大小：631808
    • 提供者：weixin_42104366

  1. jaffa-rpc-library：:rocket:高性能RPC库，用于使用ZeroMQKafkaHTTP1.11.1RabbitMQgRPC的Java Spring应用程序之间的通信-源码

  2. Jaffa RPC库 该库提供Java Spring应用程序之间的RPC通信。 主要特点： Apache ZooKeeper（带有TLSv1.2）用于服务发现 同步和异步RPC调用-通信类型由客户端而不是服务器确定 一个接口可以有多个服务器实现-客户端通过在请求中指定目标的jaffa.rpc.module.id来选择所需的接口 同步/异步调用的请求范围超时 用于缓存服务发现信息 支持5种传输协议： ZeroMQ（使用Curve进行身份验证/加密） 无限的邮件大小 低延迟 纯TCP连接 A

  3. 所属分类：其它

    • 发布日期：2021-02-23
    • 文件大小：1048576
    • 提供者：weixin_42106357

  1. goim：goim-源码

  2. goim v2.0 goim是用golang写的即时服务器。 特征 轻的 高性能 纯戈朗 支持单推，多推和广播 支持多个用户的一把钥匙（可配置的最大用户数） 支持心跳（应用程序心跳，TCP，KeepAlive，HTTP长拉） 支持身份验证（未经身份验证的用户无法订阅） 支持多种协议（WebSocket，TCP，HTTP） 可扩展的体系结构（无限的动态作业和逻辑模块） 基于Kafka的异步推送通知 建筑学 快速开始 建造 make build 跑 make run

  3. 所属分类：其它

    • 发布日期：2021-02-20
    • 文件大小：1022976
    • 提供者：weixin_42132359

  1. kaf：用Go语言编写的Apache Kafka的现代CLI-源码

  2. 卡夫 受Kubectl和Docker启发的Kafka CLI 安装 从源安装： go get -u github.com/birdayz/kaf/cmd/kaf 安装二进制文件： curl https://raw.githubusercontent.com/birdayz/kaf/master/godownloader.sh | BINDIR=$HOME/bin bash 通过在Archlinux上安装： yay -S kaf 用法 添加没有身份验证的本地Kafka kaf config

  3. 所属分类：其它

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

  1. kafka-twitter-spark-streaming：实时计算每个用户的推文-源码

  2. Apache Kafka的Twitter和Spark流 该项目实时统计每个用户包含＃GoTS7主题标签的推文。 此外，还会打印用户名和推文计数。 代码说明 身份验证操作已通过Python的Tweepy模块完成。 为Twitter流创建了名为KafkaPushListener的StreamListener。 StreamListener为Kafka Consumer生成数据。 产生的数据已被过滤掉，其中包括《权力的游戏》主题标签。 创建SparkContext来连接Spark集群。 创建了

  3. 所属分类：其它

    • 发布日期：2021-02-06
    • 文件大小：3072
    • 提供者：weixin_42139252

  1. VacationRentals-2.0：使用MERN堆栈开发了度假租赁应用程序的财产预订，用户身份验证和配置文件管理模块。 必要时实现React-Redux。 将关系数据转移到NoSQL数据库。 将Kafka实现为消息队列服务。 使用JMe

  2. 度假屋（HomeAway）原型 该项目是HomeAway（ ）的副本。 纯粹出于学习目的而开发。 使用的技术： 前端：React-Redux，HTML，CSS，Bootstrap 后端：NodeJS，ExpressJS，JWT，Kafka，猫鼬 数据库：MongoDB 功能性 用户（旅行者模式） 登录 注册 搜寻地点 预定一个地方 查看资料和更新 查看过去的预订 用户（所有者模式） 添加新属性以使其可用于基于 地点 物业资料 可用预订日期 物业图片 价钱 查看资料和更新 搜索他的财产

  3. 所属分类：其它

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

  1. event-sourcing-jambo：具有DDD +聚合+使用.NET Core，Kafka e MongoDB（博客引擎）的事件源的六边形架构-源码

  2. 基于带有DDD和CQRS的事件驱动架构的解决方案。 该解决方案包含以下应用程序。 生产者Web API，它接收产生域事件的命令。 这也接收查询并返回JSON。 消费者控制台应用程序，它读取事件流并投影到MongoDB数据库。 用于身份验证和JWT生成的Web API。 要求 环境设定 如果您已经具有适用于Kafka和MongoDB的有效连接，则可以跳过此步骤，然后转到“运行应用程序”步骤。 运行./up-kafka-mongodb.sh bash脚本以将Kafka和MongoDB作为Do

  3. 所属分类：其它

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

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

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

  3. 所属分类：其它

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

  1. KafKare：Kafka监控仪表板-源码

  2. Kafka的系统监视工具。 卡夫卡雷 目录 产品特点 跨平台Kafka监控，实时数据显示桌面应用程序 监控的指标基于现实生活中的Kafka部署崩溃和最佳实践的反馈 全栈集成，利用用户身份验证来确保只有授权成员才能查看仪表板 总览 Kafkare是跨平台的Kafka监控仪表板应用程序，用于监督Kafka集群的运行状况。 显示了几个关键指标，包括消费者滞后时间，主题数量以及诸如CPU使用率和可用内存之类的系统指标。 用户可以注册一个帐户并登录以访问仪表板。 密码使用Bcrypt加密并存储在外部数据库

  3. 所属分类：其它

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

  1. 终极后端：具有cqrs graphql微服务架构，阿波罗联盟，事件源和身份验证的多租户SaaS入门套件-源码

  2. 终极后端 （WIP）：这是具有GraphQL API和GRPC微服务的企业级高级微服务模式，基于使用命令查询责任分离（CQRS）设计模式的域（DDD）。 想问问题，加入松弛频道:) 描述 这应该成为您下一个可扩展项目的后端基础。 这是一个概念证明项目，旨在实现超薄和可扩展性，并从头开始构建供生产使用的分布式数据请求和流程处理。 它具有多租户SaaS支持，可遵循不同的多租户数据库策略以及不同的解析器模式识别您的租户。 目标是让您的下一个大型项目更加出色。 要开始使用，请阅读以下说明。 同时支持和用

  3. 所属分类：其它

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

  1. Epiphany：Epiphany是Kubernetes和Docker的完全工业化自动化，以及其他内置服务组件，例如：-Kafka或RabbitMQ用于高速消息传递事件-Prometheus和Alertmanager用于通过Graphana

  2. 主显节平台 总览 主显节的核心是Kubernetes和Docker的完全自动化以及其他内置服务/组件，例如： Kafka或RabbitMQ用于高速消息传递/事件 Prometheus和Alertmanager用于使用Graphana进行监视以进行可视化 Elasticsearch和Kibana用于集中式日志记录（OpenDistro） HAProxy用于负载平衡 Postgres和Elasticsearch用于数据存储 用于身份验证的KeyCloak 保管箱（MVP），用于保护机密和其他敏

  3. 所属分类：其它

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

  1. kt：喜欢JSON的Kafka命令行工具-源码

  2. kt-一种喜欢JSON的Kafka工具 您可能感兴趣的一些原因： 在特定偏移量之间的特定分区上使用消息。 显示主题信息（例如，具有分区偏移量和领导者信息）。 修改使用者组偏移量（例如，重置或手动设置每个主题和每个分区的偏移量）。 JSON输出，可使用或等工具轻松使用。 JSON输入可通过工具促进自动化。 通过环境变量KT_BROKERS ， KT_TOPIC和KT_AUTH配置代理，主题和认证。 快速启动时间。 没有缓冲输出。 二进制密钥和有效负载可以通过base64或十六进

  3. 所属分类：其它

    • 发布日期：2021-01-30
    • 文件大小：55296
    • 提供者：weixin_42138703
« 12 »