kafka
-
【flink番外篇】16、DataStream 和 Table 相互转换示例
Flink 系列文章 一、Flink 专栏 Flink 专栏系统介绍某一知识点，并辅以具体的示例进行说明。 1、Flink 部署系列 本部分介绍Flink的部署、配置相关基础内容。…
-
60道KafKa高频题整理（附答案背诵版）
废话不多说，直接上干货 简述什么是 Kafka 的 Topic ？ Kafka 的 Topic 是一个存储消息的逻辑概念，可以认为是一个消息集合。每条消息发送到 Kafka 集群的…
-
Linux——kafka常用命令
一、前言 多多点赞，会变好看！ 多多留言，会变有钱！ 二、Kafka的常用命令包括： 1. 启动Zookeeper服务 前台启动： ./bin/zookeeper-server-s…
-
Kafka学习笔记三(生成数据发送与分区)
Kafka学习笔记三(生成数据发送与分区) Kafka的消息从生产者到集群总共分为两个线程 一个是main,一个是sender main 线程用于把消息放到 RecordAccum…
-
【Spring连载】使用Spring访问 Apache Kafka（二十一）—-提示，技巧和例子
【Spring连载】使用Spring访问 Apache Kafka（二十一）—-提示，技巧和例子Tips, Tricks and Examples 一、手动分配所有分区…
-
Kafka【应用 01】Offset Explorer Kafka 的终极 UI 工具安装+简单上手+关键特性测试（一篇学会使用 Offset Explorer）
1.The Ultimate UI Tool for Kafka 官方自称 Offset Explorer 是 Kafka 的终极 UI 工具 😄 我们看一下 官网…
-
Kafka的监控和报警机制
Kafka的监控和报警机制是保证Kafka集群的稳定和可靠运行的重要组成部分。本文将详细介绍Kafka的监控和报警机制，包括监控指标、监控工具、报警配置和报警策略等。 1. 监控指…
-
【SpringBoot系列】SpringBoot整合Kafka(含源码)
文章目录 前言 什么是Kafka? Kafka的应用场景? 日志收集： 消息系统： 用户活动跟踪： 指标和日志聚合： 事件源： 示例 版本依赖 代码 KafkaConfig Kaf…
-
一文读懂kafka消息丢失问题和解决方案
前言 今天分享一下kafka的消息丢失问题，kafka的消息丢失是一个很值得关注的问题，根据消息的重要性，消息丢失的严重性也会进行放大，如何从最大程度上保证消息不丢失，要从生产者，…
-
【Flink-Kafka-To-Mysql】使用 Flink 实现 Kafka 数据写入 Mysql（根据对应操作类型进行增、删、改操作）
【Flink-Kafka-To-Mysql】使用 Flink 实现 Kafka 数据写入 Mysql（根据对应操作类型进行增、删、改操作） 1）导入依赖 2）resources 2…
-
IDEA中运行Dinky0.7.5之KAFKA数据源调试问题解决过程
IDEA中运行Dinky0.7.5之KAFKA数据源调试问题解决过程 1. 首次代码编译 本文所使用的IDEA版本信息如下： IntelliJ IDEA 2023.1.3 (C…
-
Windows中Zookeeper与kafka的安装配置
一、Zookeeper安装与使用 1.安装包下载 直接在官网下载即可Apache ZooKeeper。 下载后直接解压到本地即可。 2.环境配置 1> 在目录中下增加data…
-
Spring for Apache Kafka Deep Dive – Part 1: Error Handling, Message Conversion and Transaction Suppo
Following on from How to Work with Apache Kafka in Your Spring Boot Application, which sho…
-
一碰就头疼的 Kafka 消息重复问题，立马解决！
一碰就头疼的 Kafka 消息重复问题，立马解决！ 一、前言 整理下消息重复的几个场景： Kafka 幂等性 Producer Kafka 事务 消费端幂等 二、案例：Kafka …
-
Kafka——管理Kafka(命令行工具)详解
目录 管理Kafka 1、主题操作（kafka-topic.sh） 1.1、创建主题(–create) 1.2、增加分区(–alter) 1.3、减少分区数…
