kafka
-
防止消息丢失与消息重复——Kafka可靠性分析及优化实践
系列文章目录 上手第一关，手把手教你安装kafka与可视化工具kafka-eagle Kafka是什么，以及如何使用SpringBoot对接Kafka 架构必备能力——kafka的…
-
08、Kafka —— 消息存储相关的配置–＞消息过期时间设置、查看主题下的消息存活时间等配置
目录 消息存储相关的配置 ★ 消息的存储介绍 ★ 消息过期时间及处理方式 演示：log.cleanup.policy 属性配置 ★ 修改指定主题的消息保存时间 演示：将 test2…
-
详解kafka中的消息日志文件：Topic消息分类、partition分区、segment分段、offset偏移量索引文件
一、Kafka简介 Kafka是一种高吞吐量的基于zookeeper协调的以集群的方式运行的分布式发布订阅消息系统，支持分区（partition）、多副本（replica），具有非…
-
Zookeeper+kafka的应用及部署
Zookeeper+kafka的应用及部署 一、Zookeeper的概念 1、Zookeeper 定义 2、Zookeeper 工作机制 3、Zookeeper 特点 4、Zook…
-
56、Flink 的Data Source 原理介绍
Flink 系列文章 一、Flink 专栏 Flink 专栏系统介绍某一知识点，并辅以具体的示例进行说明。 1、Flink 部署系列 本部分介绍Flink的部署、配置相关基础内容。…
-
kafka本地安装报错
Error: VM option ‘UseG1GC’ is experimental and must be enabled via -XX:+UnlockExperimental…
-
Kafka消息延迟和时序性详解（文末送书）
目录 一、概括 1.1 介绍 Kafka 消息延迟和时序性 1.1.1 什么是 Kafka 消息延迟？ 1.1.2 为什么消息延迟很重要？ 1.1.3 什么是 Kafka 消息时序…
-
大数据之Kafka————java来实现kafka相关操作
一、在java中配置pom junit junit 4.11 test org.apache.kafka kafka-clients 2.8.0 org.apache.kafka …
-
Kafka-多线程消费及分区设置
目录 一、Kafka是什么？ 消息系统：Publish/subscribe（发布/订阅者）模式 相关术语 二、初步使用 1.yml文件配置 2.生产者类 3.消费者类 4.发送消息…
-
【Kafka】TimeoutException: Topic device-state-in-topic not present in metadata after 60000 ms.
1.问题原因 org.springframework.kafka.KafkaException: Send failed; nested exception is org.apac…
-
一篇搞定Kafka
目录 1、Kafka的四个角色解释 2、Kafka与zookeeper的关系与环境搭建 3、Kafka入门小案例 4、Kafka分区机制 4.1、Topic在分区下如何存储消息 …
-
Zookeeper+Hadoop+Spark+Flink+Kafka+Hbase+Hive
说明 Zookeeper+Hadoop+Spark+Flink+Kafka+Hbase+Hive 完全分布式高可用集群搭建 下载 https://archive.apache.or…
-
用 docker 部署kafka
章节目录 1. 参考链接 2. 摘抄引用 2.1 Docker镜像选型 2.2 `wurstmeister/kafka`镜像简介的先决条件 2.3 简单使用 3. 安装过程 3.1…
-
kafka开启SSL认证（包括内置zookeeper开启SSL）
zookeeper和kafka的SSL开启都可单独进行 生成SSL证书 使用jre自带的keytool工具生成，linux和windows下生成的证书可以通用 生成含有一个私钥的k…
-
Kafka 使用java实现，快速入门
一、kafka的生产者和消费者 1. 生产者发送消息的流程 2. 消费者接收消息的流程 二、 java 代码实现 1. 添加依赖： org.apache.kafka kafka…
