首页
博客
源码
资源
博客
源码
写文章
发布博客
发布资源
登录
X
kafka
相关资讯
热门
最新
后端
01-01 08:00
后端
Kafka源码分析19-Producer常用配置参数
Kafka源码分析19-Producer常用配置参数,这里是关于KafkaProducer一些配置的说明,内容来自官方文档ProducerConfigs以及自己的一些个人理解,这里以官方文档保持一致,按其重要性分为三个级别进行讲述(涉及到权限方面的参数,这里先不介绍)。highimportancemediumimportance下面的这些参数虽然被描述为medium,但实际上对Producer的吞
98
后端
01-01 08:00
后端
Kafka 核心概念介绍
Kafka 核心概念介绍,Kafka概述特征发布订阅基于消息队列实时的方式对事件进行响应分布式的系统中存储内存基于消息队列的编程传统调用,在应用之间传统应用基于接口协议(http/rpc)直接调用的方式来进行通讯。缺点:强耦合解耦,如果我们通过MQ来进行通讯,那么可以做到系统之间的,服务之间不进行直接的调用。缓冲流量,如果请求数量过大的时候KafkaMQ可以缓冲流量。做到流量的消峰,保证服务的安全
98
代码人生
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
97
后端
01-01 08:00
后端
kafka集群搭建
0. 服务器准备 服务器规划 IPhostname服务服务10.10.xxx.61kafka-01zookeeper-01kafka-0110.10.xxx.62kafka-01zookeeper-...
97
后端
01-01 08:00
后端
Kafka Connect 实战 ---- 入门
前提 首先你需要了解MQ / Kafka相关的知识 本文目标 了解 Kafka Connect 基本概念与功能 什么是Kafka Connect Kafka Connect 是一款可扩展并且可靠地在...
96
代码人生
01-01 08:00
代码人生
kafka为什么有的消息的时间戳的值是-1(kafka消息顺序)
kafka为什么有的消息的时间戳的值是-1(kafka消息顺序),背景我在检索消息的时候,意外发现一些消息的时间值是-1,如下:而另外两条消息却有正常的时间。想找下相关原因,所以查阅了一下kafka官方文档,有了相关结论。官方说明kafka消息的格式有多个版本,在老版本中,是没有时间戳这个字段的。官方文档地址:ApacheKafka按照文档说明,在0.11之前的版本中,消息的发送和存储都是在消息集
94
后端
01-01 08:00
后端
Kafka笔记
原创文章,转载请注明原文章地址,谢谢! 消息队列的两种模式 点对点模式(一对一,消费者主动拉取数据,消息收到后消息清除)消息生产者生产消息发送到Queue中,然后消息消费者从Queue中取出并且消费...
94
代码人生
01-01 08:00
代码人生
kafka 源码调试环境搭建以及踩坑记录
kafka 源码调试环境搭建以及踩坑记录,前言闲来无事想搭看看kafka源码,本以为是个非常简单的事情,结果,遇到的坑困扰我一整天搭建步骤准备gradlescalajvm(自行安装)kafka源码包idea(自行安装)zk(自行安装)gradle下载地址为:gradle.org/releases/,笔者使用的版本是3.1配置环境变量解压之后将路径添加到环境变量中即可,其中GRADLE_HOME/b
94
后端
01-01 08:00
后端
Kafka源码分析15-消息发送完了内存怎么处理?
Kafka源码分析15-消息发送完了内存怎么处理?,Kafka源码分析14-如何处理响应消息Producer已经成功把消息发送出去了,本文分析生产者成功发送消息之后内存怎么处理?直接看Sender线程的completeBatch()方法:privatevoidcompleteBatch(RecordBatchbatch,ProduceResponse.PartitionResponserespon
93
后端
01-01 08:00
后端
kafka 消息丢失和重复消费
kafka 消息丢失和重复消费,在使用mq中间件时,如果消费数据处理不当可能会引起消息丢失和重复消费的问题。本文针对kafka的这两个问题进行场景分析和可行性方案说明。消息丢失消息丢失一般指消息发送方producer和消息消费方consumer两方面。producer消息发送方可以通过配置request.required.acks属性来保证消息的安全发送,值包括:0:表示不进行消息接收是否成功的确
93
«
1
2
3
4
5
6
7
8
9
10
11
»