dy.f
- 浏览: 554848 次
- 性别:
- 来自: 广州
-
文章分类
- 全部博客 (605)
- JAVA笔霸 (20)
- JAVA面霸 (27)
- MySQL面 (21)
- LINUX面 (12)
- 并发面霸 (41)
- 架构面霸 (19)
- 综合面霸 (10)
- Spring面 (12)
- Dubbo面 (13)
- RabbitMQ面 (8)
- Kafka面 (8)
- zk面霸 (5)
- Netty面 (8)
- 网络面霸 (7)
- JVM面霸 (12)
- Cloud面 (7)
- Spring核面 (4)
- 设计模式 (22)
- JAVA核面 (4)
- 打好基础 (18)
- Redis面 (9)
- JAVA (28)
- Spring (18)
- LINUX (21)
- MySQL (43)
- Nginx (8)
- 架构 (15)
- 本地环境 (25)
- 安装配置 (4)
- 计算机组成 (1)
- 未分类 (20)
- ES (15)
- Code (24)
- 芋道面 (3)
- 多线程并发编程 (4)
- 理解IO (3)
- 原理机制 (5)
- TCP/IP/HTTP (4)
- Maven (7)
- MQ (3)
- 面试经历 (2)
- ES组件 (2)
- Spring基础 (3)
- Kafka现场问题支持 (1)
- Redis客户端 (5)
最新评论
分享到：
发表评论
-
Java面试与技术工具
2023-07-23 11:28 238怎么找到最耗费 CPU 的 Java 线程 简要介绍步骤 ... -
Kafka之数据存储
2020-01-13 15:43 327https://matt33.com/2016/03/08 ... -
【分布式】Zookeeper的Leader选举-选举过程介绍比较清晰 ( zookeeper选举只看这一篇 )
2020-01-04 10:42 164https://blog.csdn.net/gaoshan ... -
SpringMVC：SpringMVC启动初始化过程
2019-12-26 23:40 136https://segmentfault.com/a/11 ... -
Java集合-ConcurrentHashMap工作原理和实现JDK8
2019-12-25 09:43 167https://www.jianshu.com/p/85d ... -
负载均衡 Nginx、Dubbo、Ribbon
2019-12-20 20:57 204https://www.jianshu.com/p/430 ... -
Mybatis常见面试题(转)
2019-12-17 11:33 199https://www.cnblogs.com/huaji ... -
Thrift协议
2019-12-17 11:17 290https://blog.csdn.net/oBuShan ... -
网络编程面试题
2019-12-16 11:27 159https://www.cnblogs.com/jeake ... -
OAuth2.0最简向导
2019-11-18 17:19 303http://static.iocoder.cn/OAut ... -
JAVA基础再回首
2017-11-10 11:08 302JAVA基础再回首 http://www.jianshu. ... -
Http Basic Authentication in Java using HttpClient?
2017-10-12 16:34 634Http Basic Authentication in J ... -
log4j2<PatternLayout>子节点浅析
2017-05-26 19:49 1461log4j2<PatternLayout>子节 ... -
BlockingQueue的使用
2016-06-28 10:11 532BlockingQueue的使用 http://www.c ... -
tomcat session共享
2014-10-21 16:02 440tomcat session共享 学习笔记，转自：htt ... -
深入Java集合学习系列：HashMap的实现原理
2014-03-07 20:20 478学习笔记，转自：http://zhangshixi.iteye ... -
java自带线程池和队列详细讲解
2014-02-26 07:48 598学习笔记，转自：http://blog.csdn.net/sd ... -
Java内部类的使用小结
2014-02-16 22:43 612学习笔记，转自：http://android.blog.51c ... -
JAVA 常见的异常类型
2013-07-10 00:38 7781)、NullPointerException（值为空）： ... -
261个Java基础问题
2013-06-27 00:13 941学习笔记，转自：http://tianhailong.co ...
相关推荐
使用 Kafka Lag Exporter 监控 Kafka 消费者组延迟 作为 Java 应用程序运行 作为 Docker 镜像运行 故障排除 Kafka ACL 所需的权限 估计消费者组时滞 Strimzi Kafka 集群观察者 使用 Grafana 进行监控 在没有 ...
### Kylin与Kafka结合实现流式报表计算 #### 一、引言 在大数据处理领域，实时数据处理越来越受到重视。随着业务的发展和技术的进步，企业对于数据分析的需求也在不断升级，传统的批处理方式已无法满足现代业务...
卡夫卡滞后监控器监控卡夫卡滞后并将指标发布到不同的指标后端指标支持的指标后端是Prometheus和InfluxDB样本指标普罗米修斯： 可以在/prometheus端点上访问Prometheus格式的度量# HELP kafka_consumer_lag_max # ...
在部署 Kafka-Eagle 之前，需要确保 Kafka 和 ZooKeeper 已经正确安装并运行。开启 Kafka 的 JMX 端口是必要的，因为 Kafka-Eagle 需要通过 JMX 接口收集监控数据。JMX 是 Java 平台的一个标准扩展，允许应用程序...
总结来说，Kafka的Lag是监控和管理Kafka集群性能的关键指标，通过`kafka-python`库可以实现自定义的方式来获取它。上述代码示例提供了一个基础的实现，但实际使用时可能需要根据具体场景进行调整，例如处理多主题、...
《Kafka技术内幕：图文详解Kafka源码设计与实现》是一本深入解析Apache Kafka的专著，旨在帮助读者理解Kafka的核心设计理念、内部机制以及源码实现。这本书结合图文并茂的方式，使得复杂的概念变得更为易懂。同时，...
标题"使用netty实现TCP长链接消息写入kafka以及kafka批量消费数据"揭示了这个项目的核心内容：通过Netty接收TCP长连接的数据，并将这些数据存储到Kafka中，同时利用Kafka的批量消费功能对数据进行处理。下面我们将...
在SpringBoot应用中集成Kafka，我们可以使用Spring for Apache Kafka提供的API，轻松地实现消息的生产和消费。 接下来，我们讨论ProtoBuf（Protocol Buffers）。它是Google开发的一种数据序列化协议，类似于XML、...
### Kafka与Flink流计算集成知识点详解 #### 一、Kafka集群的安装与配置 **1. Kafka安装** - 使用自带版本安装Kafka，查看所在目录。 **2. 配置Kafka环境变量** - 编辑`/etc/profile`文件，添加Kafka环境变量，...
Kafka自LinkedIn开源以来就以高性能、高吞吐量、分布式的特性著称，本书以0.10版本的源码为基础，深入分析了Kafka的设计与实现，包括生产者和消费者的消息处理流程，新旧消费者不同的设计方式，存储层的实现，协调者...
Kafka 生产者和消费者实现源码 下载前你可以先看一下我的博文 https://blog.csdn.net/xy596356456/article/details/121910260 你也可以按照我的文章一步步实现
Kafka技术内幕：图文详解Kafka源码设计与实现 PDF 下载 Kafka技术内幕：图文详解Kafka源码设计与实现 PDF 下载
《Kafka技术内幕》这本书深入剖析了Apache Kafka这一分布式流处理平台的设计原理和实现细节，旨在帮助读者理解Kafka的核心机制，并能有效地运用到实际项目中。以下是对Kafka源码设计与实现的一些关键知识点的详细...
同样，Flink 提供了 Kafka Sink 来实现这一功能。在 XML 配置中，我们可以这样配置： ```xml <kafka> <bootstrap.servers>localhost:9092 <topic>output-topic <name>key.serializer <value>org.apache....
在本文中，我们将深入探讨Kafka的基础代码实现，包括客户端和服务端的交互。 **1. Kafka架构** Kafka的核心组件包括生产者(Producer)、消费者(Consumer)、主题(Topic)和 broker。生产者负责发布消息到主题，消费者...
本文将深入探讨如何实现Storm与Kafka的集成，重点在于如何从Kafka中读取数据。 **一、整合说明** Apache Storm是一个开源的分布式实时计算系统，它能够持续处理无限的数据流，确保每个事件都得到精确一次（Exactly...
本主题将深入探讨如何使用Apache Kafka和Log4j来实现日志的集中管理和处理。Kafka是一个高吞吐量、分布式的消息发布订阅系统，而Log4j则是一款广泛使用的Java日志框架，二者结合能有效提升日志处理效率和分析能力。 ...
Kafka技术内幕及源码设计与实现（第三部分），很好的一本书。
Kafka高可用性实现原理 Kafka 作为一个分布式消息系统，具有高可用性和高吞吐量的特点。其高可用性实现原理可以从以下几个方面来分析： 1. 分布式系统架构 Kafka 的架构是基于分布式系统的，包括 Producer、...
Kafka自LinkedIn开源以来就以高性能、高吞吐量、分布式的特性著称，本书以0.10版本的源码为基础，深入分析了Kafka的设计与实现，包括生产者和消费者的消息处理流程，新旧消费者不同的设计方式，存储层的实现，协调者...