1背景和需求银行业务应用系统每天有大量的交易发生，这些交易很多需要进行实时的业务核查与处理，譬如一笔交易发生，这笔交易是否是欺诈交易，这笔交易是否已经达到限额了，相关用户是否在黑名单中，交易结果联动短信、Email渠道通知用户等等，典型的一笔简单的资金转账交易，就要与反欺...(more)

众所周知，ApacheKafka是一个分布式开源流和事件处理平台，广泛应用于各大互联网公司以及基于不同体系的软件架构的业务场景中。其实，基于早期的设计理念而言，Kafka最初被设想为消息队列，并基于分布式提交日志的抽象。然而，自2011年由LinkedIn创建并开源以来，Kafka已迅速从消息队...(more)

Hellofolks，我是Luga，今天我们来分享一下与Kafka有关的观测性话题-Kafdrop。作为一个构建在SpringBoot之上的免费WebUI工具，越来越受到广大技术人员的喜好。—01—背景概述Kafdrop是一个Apache2.0许可项目，作为一款ApacheKafkaWebUI可视化工具，在无数的开源选项中，Kafdrop以其...(more)

1.整体架构图：2.实验环境准备：各组件简单介绍：Elasticsearch:是一个基于Lucene的搜索服务器。提供搜集、分析、存储数据三大功能。它提供了一个分布式多用户能力的全文搜索引擎，基于RESTfulweb接口。Elasticsearch是用Java开发的，并作为Apache许可条款下的开放源码发布，是当前...(more)

网站：1、helm的官方网站：https://helm.sh/备注：主要是可以查看相关的文档方便2、char包的离线下载url：https://github.com/helm/charts备注：可以直接下载下来，然后传到服务器上3、char包的在线下载url：https://hub.kubeapps.com/备注：服务器可以连接外网时使用备注：这篇文章目前只...(more)

本故事纯属虚构，如有雷同，纯属巧合，一笑了之。公司分配给了A和B一个任务，测试容器化Kafka集群的性能。之前B在老机器上已经测试过一个版本，并写了完整的报告，算是有经验的老鸟了。现在到了一批新机器，需要在它们上面重新测试一下Kafka的性能，A主动承担这个该任务，要知道新机器不管...(more)

今天给大家介绍一个强大的开源流处理平台——Kafka--Kafka是什么？ApacheKafka是一个分布式发布-订阅(Pub-Sub)消息系统和一个强大的队列，可以处理大量的数据，能够将消息从一个端点传递到另一个端点。它的消息保留在磁盘上，并会在群集内复制以防止数据丢失。此外，Kafka需要构建...(more)

背景介绍Kafka简介Kafka是一种分布式的，基于发布/订阅的消息系统。主要设计目标如下：以时间复杂度为O(1)的方式提供消息持久化能力，并保证即使对TB级以上数据也能保证常数时间的访问性能高吞吐率。即使在非常廉价的商用机器上也能做到单机支持每秒100K条消息的传输支持Kafka...(more)

一、券商实施个性化推荐项目的必要性1.1个性化推荐技术发展背景目前，随着用户接收到的信息量爆炸般增长，传统的推荐以及服务方式的边际收益正在不断减少，用户个性化的需求变得越来越多。大数据实时个性化服务，主要基于大数据用户画像、产品画像建设成果，结合实时流计算框架，以...(more)

本文要给大家分享的是我们如何去构建一个日志系统、用到了那些技术、为什么用这些技术，同时会讲述这个过程中遇到的问题及优化方法，希望能给你在实践中能够提供一些参考。前言最近在维护一个有关于日志的项目，这个项目是负责收集、处理、存储、查询京东卖家相关操作的日志，我...(more)