最新 最热

SpringBoot 整合 Kafka 实现数据高吞吐

在上篇文章中,我们详细的介绍了 kafka 的架构模型,在集群环境中,kafka 可以通过设置分区数来加快数据的消费速度。

2022-12-04
1

SpringCloud Alibaba(五) - RocketMQ

下载地址:https://rocketmq.apache.org/release-notes/

2022-12-03
1

基于STM32与FreeRTOS的消息传递详解(HAL库)

我们在裸机开发中,每个函数之间进行数据通信往往采用全局变量。而在嵌入式开发中。我们在进行进程间通信的时候,往往采用消息队列。对于操作系统来说,消息队列是非常重要的一个数据结构。本文将介绍一下,如何使用消息队列...

2022-12-03
1

ES09# Filebeat配置项及吞吐调优项梳理

公司有使用filebeat作为日志采集的agent,然而最近发现其在一些node采集吞吐不足,现就其配置项与吞吐调优进行梳理。本文的主要内容有:

2022-12-03
0

高级性能测试系列《29.WebSocket request-response Sampler、MQ环境搭建》

http、websocket协议的数据报文,都可以通过抓包工具抓包,例如直接按f12。

2022-12-02
0

图解 kafka 架构与工作原理

实时数据处理,从名字上看,很好理解,就是将数据进行实时处理,在现在流行的微服务开发中,最常用实时数据处理平台有 RabbitMQ、RocketMQ 等消息中间件。...

2022-12-02
1

使用 NiFi、Kafka、Flink 和 DataFlow 进行简单的信用卡欺诈检测

随着越来越多的人呆在家里,让我们的信用卡代步,网上购物正在兴起。不幸的是,与这一趋势保持同步的是信用卡欺诈的增加。

2022-12-02
1

在CDP平台上安全的使用Kafka Connect

在这篇文章中,将演示如何将 Kafka Connect 集成到 Cloudera 数据平台 (CDP) 中,从而允许用户在 Streams Messaging Manager 中管理和监控他们的连接器,同时还涉及安全功能,例如基于角色的访问控制和敏感信息处理。如果您...

2022-12-02
1

Cloudera 流处理社区版(CSP-CE)入门

Cloudera 在为流处理提供综合解决方案方面有着良好的记录。Cloudera 流处理 (CSP) 由 Apache Flink 和 Apache Kafka 提供支持,提供完整的流管理和有状态处理解决方案。在 CSP 中,Kafka 作为存储流媒体底层,Flink 作为核...

2022-12-02
1

将流转化为数据产品

每个大型企业组织都在尝试加速其数字化转型战略,以更加个性化、相关和动态的方式与客户互动。在创建和收集数据时对数据执行分析(也称为实时数据流)并生成即时洞察以加快决策制定的能力为组织提供了竞争优势。...

2022-12-02
1