首页
博客
源码
资源
博客
源码
写文章
发布博客
发布资源
登录
X
kafka
相关资讯
热门
最新
后端
01-01 08:00
后端
Kafka 核心概念介绍
Kafka 核心概念介绍,Kafka概述特征发布订阅基于消息队列实时的方式对事件进行响应分布式的系统中存储内存基于消息队列的编程传统调用,在应用之间传统应用基于接口协议(http/rpc)直接调用的方式来进行通讯。缺点:强耦合解耦,如果我们通过MQ来进行通讯,那么可以做到系统之间的,服务之间不进行直接的调用。缓冲流量,如果请求数量过大的时候KafkaMQ可以缓冲流量。做到流量的消峰,保证服务的安全
101
代码人生
01-01 08:00
代码人生
kafka-jstorm实时代码
kafka-jstorm实时代码 package comdoctor.kafkajstrom; import java.util.HashMap; import java.util.Map; import java.util.concurrentTimeUnit; import org.apache.commons.lang.RandomStringUtils; import org.s
101
后端
01-01 08:00
后端
kafka表引擎使用
clickhouse使用kafka表引擎消费kafka数据
101
代码人生
01-01 08:00
代码人生
kafka为什么有的消息的时间戳的值是-1(kafka消息顺序)
kafka为什么有的消息的时间戳的值是-1(kafka消息顺序),背景我在检索消息的时候,意外发现一些消息的时间值是-1,如下:而另外两条消息却有正常的时间。想找下相关原因,所以查阅了一下kafka官方文档,有了相关结论。官方说明kafka消息的格式有多个版本,在老版本中,是没有时间戳这个字段的。官方文档地址:ApacheKafka按照文档说明,在0.11之前的版本中,消息的发送和存储都是在消息集
99
后端
01-01 08:00
后端
kafka集群搭建
0. 服务器准备 服务器规划 IPhostname服务服务10.10.xxx.61kafka-01zookeeper-01kafka-0110.10.xxx.62kafka-01zookeeper-...
99
后端
01-01 08:00
后端
Kafka Connect 实战 ---- 入门
前提 首先你需要了解MQ / Kafka相关的知识 本文目标 了解 Kafka Connect 基本概念与功能 什么是Kafka Connect Kafka Connect 是一款可扩展并且可靠地在...
99
后端
01-01 08:00
后端
Kafka笔记
原创文章,转载请注明原文章地址,谢谢! 消息队列的两种模式 点对点模式(一对一,消费者主动拉取数据,消息收到后消息清除)消息生产者生产消息发送到Queue中,然后消息消费者从Queue中取出并且消费...
97
后端
01-01 08:00
后端
Kafka源码分析15-消息发送完了内存怎么处理?
Kafka源码分析15-消息发送完了内存怎么处理?,Kafka源码分析14-如何处理响应消息Producer已经成功把消息发送出去了,本文分析生产者成功发送消息之后内存怎么处理?直接看Sender线程的completeBatch()方法:privatevoidcompleteBatch(RecordBatchbatch,ProduceResponse.PartitionResponserespon
96
后端
01-01 08:00
后端
kafka 消息丢失和重复消费
kafka 消息丢失和重复消费,在使用mq中间件时,如果消费数据处理不当可能会引起消息丢失和重复消费的问题。本文针对kafka的这两个问题进行场景分析和可行性方案说明。消息丢失消息丢失一般指消息发送方producer和消息消费方consumer两方面。producer消息发送方可以通过配置request.required.acks属性来保证消息的安全发送,值包括:0:表示不进行消息接收是否成功的确
96
后端
01-01 08:00
后端
kafka 基础知识大全
本文包括kafka的定义、安装、启动、架构、工作流程、原理、生产者、消费者、分区、ISR节点、HW、分区分配策略、offset、高效读写机制。 1. Kafka 概述 1.1 定义 Kakfa 是一...
95
«
1
2
3
4
5
6
7
8
9
10
11
»