文章浏览阅读1.6k次。前言 系统间的耦合高怎么办,我们如何不让一个服务过于庞大,一个好的方式就是依据具体的功能模块拆分服务,降低服务的耦合度,服务间的交互可以通过消息传递数据来实现,除此之外Kafka非常适......
2024-01-23 11:06 阅读 阅读全文文章浏览阅读1k次。外部系统的集成,即通过不同的生产端或消费端来实现数据消费过程。1、集成flumeflume是大数据开发者常用的组件,主要是高可用高可靠的日志系统,通过编写.conf文件来实现对日志文件的收集后转存到文件或......
2024-01-22 17:05 阅读 阅读全文文章浏览阅读417次。4.1 Kafka源码剖析之源码阅读环境搭建首先下载源码:http://archive.apache.org/dist/kafka/1.0.2/kafka-1.0.2-src.tgzgradle-4.8.1下载地址:https://services.gradle.org/distributions/gradle-4.8.1-bin.zipScala-2.12.12下载地址:https://downloads.lightbe......
2023-11-11 18:10 阅读 阅读全文//基于fork()系统调用//#include "sys/types.h"//包含pid_t等的声明//#include "sys/file.h"//#include "unistd.h"//包含pipe(),fork()等的声明#include "stdlib.h"//包含exit(),pid_t等的声明#include "string.h"//包含strcpy()等的声明......
2023-10-14 13:24 阅读 阅读全文文章浏览阅读404次。1.kafka定义Kafka是一个分布式消息队列:生产者、消费者的功能。Kafka可以解决:并发、解耦、异步2.kafka主要组件Producer: 生产者负责获取数据并将数据上传到Kafka的,比如flume、logstash 生产者往往是监控一个......
2024-01-22 22:32 阅读 阅读全文