如何用Know Streaming 快速对Kafka Topic 完成扩缩副本操作
扩缩副本功能是原生Kafka没有的功能，或者说是没有直接提供的功能。但是对于扩缩副本这么一个操作功能, 是属与平时不会用, 想用的时候干着急。比如一开始你的Topic副本数填的是1, 运行了一段时间之后发现, 1的副本可不行啊, 高可用性大大降低, 需要扩副本。但是你想要扩副本的时候才发现, kaf
kafka笔记4--安装kafka ui
kafka笔记4--安装kafka ui1 介绍2 安装 & 测试2.1 docker 部署 kafka-ui2.2 测试3 注意事项4 说明1 介绍文章 Overview of UI Tools for Monitoring and Management of Apache Kafka Clust
20道常见的kafka面试题以及答案
1、kafka的消费者是pull(拉)还是push(推)模式，这种模式有什么好处？2、kafka维护消息状态的跟踪方法3、zookeeper对于kafka的作用是什么?4、kafka判断一个节点还活着的有那两个条件？5、讲一讲 kafka 的 ack 的三种机制6、kafka 分布式（不是单机）的情
RocketMQ 介绍及基本概念
1 介绍RocketMQ作为一款纯java、分布式、队列模型的开源消息中间件，支持事务消息、顺序消息、批量消息、定时消息、消息回溯等。1.1 RocketMQ 特点支持发布/订阅（Pub/Sub）和点对点（P2P）消息模型在一个队列中可靠的先进先出（FIFO）和严格的顺序传递 （RocketMQ可以
kafka简介
Kafka 本质上是⼀个消息队列。与zeromq不同的是，Kafka是一个独立的框架而不是一个库。这里主要介绍其原理，至于具体的安装等操作不做介绍，只是提示一下，第一次运行时，先设置前台运行，看会不会报错。架构注意下图没有画上zookeeper，请自行脑补。kafka需要连接到zookeeper，来
Kafka扩分区和分区副本重分配之后消费组会自动均衡吗？
扩分区之后 消费组会不会重新平衡呢？那我们今天从源码的角度来一起分析一下, 扩分区能否重平衡？
Linux搭建zookeeper与kafka集群配置
Kafka依赖zk，以集群方式工作，每台机器称为一个blocker（与其他分布式环境不同的是，仅有1台blocker也能工作），并分别指定blockerId，kafka中同一类型数据以topic形式存在，可对topic进行分区，及指定副本数，例如可将 topic1 分区为3个partition:p0
Kafka+SpringBoot 入门案例1
kafka+springboot入门案例
开发人员提高开发效率的10个推荐工具
推荐10个能够提高开发人员开发效率的10个工具
使用Docker搭建Apache Kafka环境
本文使用Docker技术创建单个Kafka节点和Kafka集群环境，并且使用可视化工具连接服务查看代理服务器的配置信息。
大数据面试重点之kafka(四)
大数据面试重点之kafka(四)
Kafka入门教程
Apache Kafka是一个分布式消息发布订阅系统。它最初由LinkedIn公司基于独特的设计实现为一个分布式的提交日志系统( a distributed commit log)，之后成为Apache项目的一部分。Kafka采用订阅-发布模式提供消息服务，支持不同消费组分别消费。在性能方面，它具有
[Spark、hadoop]Spark Streaming整合kafka实战
Kafka是由Apache软件基金会开发的一个开源流处理平台,它使用Scala和Java语言编写，是一个基于Zookeeper系统的分布式发布订阅消息系统，该项目的设计初衷是为实时数据提供一个统一、高通量、低等待的消息传递平台。①、Kafka的众多优点：其优点具体：(1)解耦。Kafka 具备消息系
大数据面试之kafka重点（二）
大数据面试之kafka重点（二）
Kafka SASL/PLAIN加密 及Kafka-Python整合
SASL/PLAIN是kafka中一种使用用户名/密码的身份验证机制，本文使用Kafka-Python2.02 及kafka3.2.0进行简单的整合操作。
[Spark、hadoop]spark Streaming的核心DStream
1.SparkStreaming提供了一个高级抽象的流，即DStream(离散流)。2.DStream的内部结构是由一系列连续的RDD组成，每个RDD都是一小段由时间分隔开来的数据集。
[平台运维、Hadoop]kafka streams概述
Kafka Streams是Apache Kafka开源项目的一个流处理框架，它是基于Kafka的生产者和消费者,为开发者提供了流式处理的能力,具有低延迟性.高扩展性、高弹性、高容错性的特点，易于集成到现有的应用程序中。KafkaStreams是一套处理分析Kafka中存储数据的客户端类库，处理完的
Docker搭建Kafka集群
详细讲解docker如何搭建Kafka集群
kafka是啥？虽然很难学，但是实验入门很简单
Kafka是一个分布式的基于发布/订阅模式的消息队列（Message Queue），主要应用于大数据实时处理领域。kafka的三个基本组成是生产者、消费者、broker（生产者和消费者之间的消息队列服务器）。发布/订阅：消息的发布者不会将消息直接发送给特定的订阅者，而是将发布的消息分为不同的类别，订
Zookeeper和Kafka on k8s 部署
Apache ZooKeeper 是一个集中式服务，用于维护配置信息、命名、提供分布式同步和提供组服务，ZooKeeper 致力于开发和维护一个开源服务器，以实现高度可靠的分布式协调，其实也可以认为就是一个分布式数据库，只是结构比较特殊，是树状结构。Kafka是最初由 Linkedin 公司开发，是
