kafka
-
Kafka 监听器详解
Kafka 监听器详解 Kafka Assistant 是一款 Kafka GUI 管理工具——管理Broker,Topic,Group、查看消费详情、监控服务器状态、支持多种消息…
-
windows/linux 安装zookeeper + Kafka (含自启动)运行教学
首先我们来花两分钟了解一下: 什么是zookeeper? 什么是kafka? 为什么kafka依赖zookeeper和javaSDK? Zookeeper 和 Kafka 都是 A…
-
kafka系列:windows安装kafka
文章目录 一、jdk安装 二、安装zookeeper 1、下载并解压zookeeper 2、修改zoo.cfg配置文件 3、添加zookeeper环境变量 4、启动zookeepe…
-
【flink番外篇】22、通过 Table API 和 SQL Client 操作 Catalog 示例
Flink 系列文章 一、Flink 专栏 Flink 专栏系统介绍某一知识点,并辅以具体的示例进行说明。 1、Flink 部署系列 本部分介绍Flink的部署、配置相关基础内容。…
-
Kafka 简介
目录 1、概念介绍 Kafka 由来 ZooKeeper Kafka 特性 Kafka 使用场景 Kafka 复制备份 2、Kafka 架构 Broker Topic Produ…
-
三、Kafka生产者4—核心组件[元数据]-Metadata
概述: 本文主要分享Kafka客户端的元数据如何创建,及其内部结构和对象 一、介绍MetaData 客户端元数据在初始化生产者客户端时被创建,以缓存的形式保存在客户端本地内存中; …
-
kafka-consumer-groups.sh消费者组管理
1.查看消费者列表 –list bin/kafka-consumer-groups.sh –bootstrap-server hadoop102:9092,hadoo…
-
Flink实现kafka到kafka、kafka到doris的精准一次消费
1 流程图 2 Flink来源表建模 –来源-城市topic CREATE TABLE NJ_QL_JC_SSJC_SOURCE ( record string ) WITH (…
-
jmeter简单压测kafka
前言 这也是一个笔记,就是计划用jmeter做性能测试,但是这里是只要将数据放到kafka的topic里,后面查看下游业务处理能力。 一、方案 因为只要实现…
-
Grafana Prometheus 通过JMX监控kafka 【2023最新方式】
第三方kafka exporter方案 目前网上关于使用Prometheus 监控kafka的大部分资料都是使用一个第三方的 kafka exporter,他的原理大概就是启动一个…
-
Scala编程 读取Kafka处理并写入Redis
部分知识(可略过) Kafka Kafka是一种分布式流处理平台,它是一个高吞吐量、可扩展、持久化的消息队列系统,用于处理实时数据流。Kafka的核…
-
深入理解Kafka3.6.0的核心概念,搭建与使用
Kafka是最初由Linkedin公司开发,是一个分布式、支持分区的(partition)、多副本的(replica),基于zookeeper协调的分布式消息系统,它的最大的特性就…
-
开源的数据流技术,该选择Redpanda还是Apache Kafka?
本文将比较Apache Kafka和Redpanda两种开源的数据流技术,在云原生实时处理能力上的不同,以及如何在项目中做出选择。 目前,Apache Kafka不但成为了数据…
-
ERROR Fatal error during KafkaServer startup. Prepare to shutdown (kafka.server.KafkaServer) kafka.c
文章目录 问题描述: 原因分析: 解决方案: 方法一: 方法二: 问题描述: 开启 ZooKeeper 之后,准备启动 Kafka 服务,结果出现 ERROR Fatal erro…
-
聊聊kafka client性能调优及kafka最佳实践
这里是weihubeats,觉得文章不错可以关注公众号小奏技术,文章首发。拒绝营销号,拒绝标题党 背景 最近在使用kafka的时候遇到了一些性能问题。 所以就打算研究下kafka相…
