Flink实现同时消费多个kafka topic，并输出到多个topic
flink同时消费多个kafka topic，并输出到多个topic
Kafka学习笔记
Kafka是一个分布式的流媒体平台（存储、计算）应用：消息系统、日志收集、用户行为追踪、流式处理（对数据流）高吞吐量：可以处理TB级的海量数据，因为消息持久化消息持久化：消息存在硬盘里，对硬盘顺序读写（性能高于对内存的随机读取）高可靠性：分布式的，可以集群部署，一台挂了还有别的高扩展性：一个集群，如
kafka tool下载安装和使用
kafka tool工具下载 安装 和使用
Kafka安装及启动用法详解
Kafka安装及启动用法详解
KafKa -相关参数优化
broker 处理消息的最大线程数，默认为 3，建议设为 cpu 核数 + 1：例如：cpu 核数 8 ：2. 处理磁盘 IO 的线程数broker 处理磁盘 IO 的线程数，建议设为 cpu 核数 x 2 ：例如：cpu 核数 8：3. 数据落盘策略Kafka重度依赖底层操作系统提供的功能。当上层
实战：Spring Cloud Stream集成兼容多消息中间件kafka、rabbitmq
Spring Cloud Stream集成多消息中间件kafka、rabbitmq较为简单，直接省去了原生中间的的操作与处理，开发人员可以直接任意切换和混用多种消息中间件，大大增加架构的可用性与可移植性。本实战案例提供重试、私信、手动ack、消费者分组和负载等高可用方案，直接可接入生产使用。
Kafka学习笔记
kafka
Flink反压如何排查
Flink反压如何排查，是我们在进行flink开发以及监控的流程中必不可少的一项技能，同时也是很多大厂面试需要问题的知识点。
云服务部署kafka 报错：“docker run“ requires at least 1 argument.
这里需要注意一下有一个小坑，如果你之前一直是部署在自己电脑的虚拟机上的最后-p的命令使用的是--net=host wurstmeister/kafka:2.12-2.3.1，创建容器指令：docker run -d --name zookeeper -p 2181:2181 zookeeper:3.
Kafka - 主题Topic与消费者消息Offset日志记录机制
kafka topic分区存储消息以及 消息信息存储的形式与日志记录
如何保证Mq消息不丢失
mq: rabbitmq, rocketmq, kafka
RabbitMq、Kafka、RocketMq整理
MQ的主要作用：异步提高性能、解耦提高扩展性、削峰。
⼤数据采集和可视化系统实现
前言本篇博客用来记录 2022年春季大数据课程结课大作业（大三下，前8周，小组作业）非常感谢小组同学的付出和积极配合！文章目录1. 实验目的2. 实验环境3. 实验要求4. 实验内容4.1 准备工作4.2 数据的采集和发送4.2.1 流程介绍4.2.2 实验过程4.2.3 源码解析4.3 数据的消费
一文读懂kafka消息丢失问题和解决方案
今天分享一下kafka的消息丢失问题，kafka的消息丢失是一个很值得关注的问题，根据消息的重要性，消息丢失的严重性也会进行放大，如何从最大程度上保证消息不丢失，要从生产者，消费者，broker几个端来说。关于kafka的消息丢失问题和解决方案就说到这里，我们分别从生产者到broker，broker
kafka知识点全方位讲解
Apache Kafka是一个开源消息系统，由Scala写成。是由Apache软件基金会开发的一个开源消息系统项目。Kafka最初是由LinkedIn开发，并于2011年初开源。2012年10月从Apache Incubator毕业。该项目的目标是为处理实时数据提供一个统一、高通量、低等待的平台。K
2、NIFI应用示例-GetFile和PutFile应用
3、NIFI处理器介绍、监控等4、集群部署及验证、监控及节点管理5、NIFI FileFlow示例、模板以及拓扑6、NIFI 表达式、监控、连接、负载均衡与集群7、NIFI综合应用场景（DB-Hdfs、json转换、mysql同步到hive、kafka同步）
【Kafka+Flume+Mysql+Spark】实现新闻话题实时统计分析系统（附源码）
【Kafka+Flume+Mysql+Spark】实现新闻话题实时统计分析系统（附源码）
【消息队列】聊一下如何避免消息的重复消费
Kafak重复消费如何解决
【kafka 监控】Kafka_exporter+prometheus 监控kafka数据
通过Prometheus的查询和可视化功能，您可以对Kafka集群进行监控和管理，以保证Kafka集群的稳定性和高可用性。您可以在Kafka_exporter的官方网站（https://github.com/danielqsj/kafka_exporter/releases）上下载最新版本的Kafk
深入理解Kafka：架构、设计原则及最佳实践
Kafka是一款由Apache开发的分布式流处理平台，它最初是由LinkedIn公司在2010年开发的。从最初的消息队列到如今的分布式流处理平台Kafka经历了一个逐步演化的过程。Kafka最开始的设计目的是解决LinkedIn内部存在的海量数据传输问题，在其不断的发展中Kafka逐渐发展成为一种可
