kafka
-
Kafka-RecordAccumulator分析
前面介绍过，KafkaProducer可以有同步和异步两种方式发送消息，其实两者的底层实现相同，都是通过异步方式实现的。 主线程调用KafkaProducer.send方法发送消息…
-
@KafkaListener注解详解（一）| 常用参数详解
@KafkaListener 注解提供了许多可配置的参数，以便更灵活地定制 Kafka 消息监听器的行为。 topics： 描述： 指定监听的 Kafka 主题，可以是一个字符串数…
-
Elasticsearch实践：ELK+Kafka+Beats对日志收集平台的实现
可以在短时间内搜索和分析大量数据。 Elasticsearch 不仅仅是一个全文搜索引擎，它还提供了分布式的多用户能力，实时的分析，以及对复杂搜索语句的处理能力，使其在众多场景下，…
-
保障效率与可用，分析Kafka的消费者组与Rebalance机制
系列文章目录 上手第一关，手把手教你安装kafka与可视化工具kafka-eagle Kafka是什么，以及如何使用SpringBoot对接Kafka 架构必备能力——kafka的…
-
kafka常用命令大全
目录 启动kafka服务 停止kafka服务 创建一个叫demo-topic的主题（topic)，有两个分区，每个分区3个副本，同时指定该主题的消息保留时长（72小时） 高版本 列…
-
kafka发送数据报错： Error connecting to node xxxxx:9092 (id: 1 rack: null)java.net.UnknownHostExceptio
报错内容： warn报错： [kafka-producer-network-thread | producer-1] WARN org.apache.kafka.clients…
-
【Spring连载】使用Spring访问 Apache Kafka（三）—-接收消息
【Spring连载】使用Spring访问 Apache Kafka（三）—-接收消息 一、消息监听器Message Listeners 二、消息监听器容器Message…
-
kafka3.X集群安装(不使用zookeeper)
一、kafka集群实例角色规划 在本专栏的之前的一篇文章《kafka3种zk的替代方案》已经为大家介绍过在kafka3.0种已经可以将zookeeper去掉。 上图中黑色代表bro…
-
【flink番外篇】9、Flink Table API 支持的操作示例（13）- Row-based（map、flatmap、aggregate、group window aggregate等）操作
Flink 系列文章 一、Flink 专栏 Flink 专栏系统介绍某一知识点，并辅以具体的示例进行说明。 1、Flink 部署系列 本部分介绍Flink的部署、配置相关基础内容。…
-
揭秘 Kafka 高性能之谜：一文读懂背后的设计精粹与技术实现
目录 一、顺序写入磁盘与I/O优化 1.1 数据在kafka中是如何存储的 二、批量处理 三、页缓存技术 四、零拷贝技术 4.1 D…
-
kafka权限认证 topic权限认证 权限动态认证-亲测成功
kafka权限认证 topic权限认证 权限动态认证-亲测成功 kafka动态认证 自定义认证 安全认证-亲测成功 MacBook Linux安装Kafka Linux解压安装Ka…
-
Kafka与Zookeeper版本对应关系
文章目录 了解 版本对应 Kafka安装包 Kafka源码包 了解 比如： kafka_2.11-1.1.1.jar包 其中2.11表示的是Scala的版本，因为Kafka服务器端…
-
Kafka某Topic的部分partition无法消费问题
今天同事反馈有个topic出现积压。于是上kfk管理平台查看该topic对应的group。发现6个分区中有2个不消费，另外4个消费也较慢，总体lag在增长。查看服务器日志，日志中有…
-
kafka服务端允许生产者发送最大消息体大小
1、kafka config服务端配置文件server.properties server.properties中加上的message.max.bytes配置，我目…
-
linux环境kafka安装及配置
linux环境kafka下载安装 下载资源 安装zookeeper kafka安装及配置 kafka安装（单体） kafka集群配置方式 kafka开启kerberos认证 kaf…
