已找到以下 10000 条记录
  • 磁盘类型及性能介绍 - 云硬盘 EVS

    磁盘类型及性能介绍 根据性能,磁盘可分为极速型SSD V2、极速型SSD、通用型SSD V2、超高IO、通用型SSD、高IO、普通IO,具体介绍如下。不同类型云硬盘的性能和价格有所不同,您可根据应用程序要求选择您所需的云硬盘。 极速型SSD云硬盘采用了结合全新低时延拥塞控制算法的RDMA(Remote

  • 管理Kafka Topic中的消息 - MapReduce服务 MRS

    管理消息 进入Kafka服务页面: 登录FusionInsight Manager,然后选择“集群 > 服务 > Kafka”。 单击“实例”,查看Kafka Broker角色实例的IP地址。 记录Kafka角色实例其中任意一个的IP地址即可。 根据业务情况,准备好客户端,参考

  • Kafka 运维部署

    mkdir /data/kafka/zk/logs mkdir /data/kafka/data mkdir /data/kafka/log/ mkdir /data/kafka/log/kafka Zookeeper配置&启动(使用的是Kafka 自带的zk) zookeeper

    作者: 程序员jeff
    发表时间: 2023-12-05 10:27:24
    0
    0
  • 查看Kafka审计日志 - 分布式消息服务Kafka版

    ailure Kafka实例创建Topic成功 kafka Kafka_create_topicSuccess Kafka实例创建Topic失败 kafka Kafka_create_topicFailure Kafka实例删除Topic成功 kafka Kafka_delete_topicsSuccess

  • 关闭Kafka Manager - 分布式消息服务Kafka版

    Manager,不会重启实例。 关闭Kafka Manager 登录管理控制台。 在管理控制台左上角单击,选择Kafka实例所在的区域。 在管理控制台左上角单击,选择“应用中间件 > 分布式消息服务Kafka版”,进入分布式消息服务Kafka专享版页面。 在左侧导航栏单击“Kafka实例”,进入Kafka实例列表页面。

  • DLI Flink作业如何动态感知Kafka分区的变化

    我使用Flink Opensource SQL, 采用Flink 1.10版本。初期Flink作业规划的Kafka的分区数partition设置过小或过大,后期需要更改Kafka区分数,很麻烦。如何不停止作业实现自动感知?

    作者: 数据湖爱好者
    6225
    3
  • kafka移植指南文档问题反馈

    你好,官方推荐的鲲鹏大数据解决方案中,kafka移植的那篇https://support.huaweicloud.com/prtg-apache-kunpengbds/kunpengbds_02_0008.html不建议使用2.1.0版本,我在实际使用中遇到过致命的bug,导致整个集群的不可用。官方推荐使用2

    作者: 呆木头
    1561
    3
  • 重启Kafka Manager - 分布式消息服务Kafka版

    约束与限制 重启Kafka Manager不会影响业务。 重启Kafka Manager 登录管理控制台。 在管理控制台左上角单击,选择Kafka实例所在的区域。 在管理控制台左上角单击,选择“应用中间件 > 分布式消息服务Kafka版”,进入分布式消息服务Kafka专享版页面。

  • 快速入门Kafka系列(4)——Kafka的主要组件说明

    r说明2、kafka当中的topic说明3、kafka当中的partition说明3、kafka当中partition的副本数说明5、kafka当中的segment说明索引文件与数据文件的关系 6、kafka当中的partition的offset7、kafka分区与消费组

    作者: 大数据梦想家
    发表时间: 2021-09-28 16:16:00
    967
    0
  • Kafka消息延迟和时序性详解

    监控和度量工具 在度量和监控 Kafka 消息延迟时,使用适当的工具和系统是至关重要的。下面是一些工具和步骤,帮助你有效地监控 Kafka 消息延迟,包括代码示例:  2.2.1 Kafka 内置度量 Kafka 提供了内置度量,可通过多种方式来监控。以下是一些示例,演示如何通过 Kafka 的 JMX

    作者: 清雨小竹
    42
    1
  • Kafka客户端使用建议 - 分布式消息服务Kafka版

    消息大小:不能超过10MB 使用SASL_SSL协议访问Kafka:确保DNS具有反向解析能力,或者在hosts文件配置Kafka所有节点IP和主机名映射,避免Kafka client做反向解析,阻塞连接建立。 磁盘容量申请超过业务量 * 副本数的2倍,即保留磁盘空闲50%左右。 业务进程JVM内存

  • A(12)Kafka分区分配策略

    Kafka内部存在两种默认的分区分配策略:Range和 RoundRobin。 Range是默认策略。Range是对每个Topic而言的(即一个Topic一个Topic分),首先对同一个Topic里面的分区按照序号进行排序,并对消费者按照字母顺序进行排序。然后用Partiti

    作者: 百忍成金的虚竹
    发表时间: 2021-03-27 15:22:32
    1593
    0
  • 重置Kafka Manager密码 - 分布式消息服务Kafka版

    前提条件 已创建Kafka实例,且实例处于“运行中”。 重置Kafka Manager密码 登录管理控制台。 在管理控制台左上角单击,选择Kafka实例所在的区域。 在管理控制台左上角单击,选择“应用中间件 > 分布式消息服务Kafka版”,进入分布式消息服务Kafka专享版页面。

  • Kafka修改配置详解

    Kafka修改配置有两个命令:kafka-topics.sh和kafka-configs.sh。kafka-topics.sh主要是修改单个topic的配置,支持修改的配置参数见附录一;kafka-configs.sh支持修改topic、broker、user和client级别的配置,支持修改的配置参数见附录二。

    作者: Summer_
    发表时间: 2022-04-28 03:50:01
    1327
    0
  • 配置Kafka高可用和高可靠 - MapReduce服务 MRS

    配置Kafka高可用和高可靠 操作场景 Kafka消息传输保障机制,可以通过配置不同的参数来保障消息传输,进而满足不同的性能和可靠性要求。本章节介绍如何配置Kafka高可用和高可靠参数。 本章节内容适用于MRS 3.x及后续版本。 对系统的影响 配置高可用、高性能的影响: 配置高

  • DMS Kafka队列

    本视频介绍如何下载Demo示例和搭建开发环境,通过管理控制台创建资源,并运行示例代码进行生产消息和消费消息。

    播放量  5281
  • 如何使用Docker内的kafka服务

    spring-kafka:1.3.8.RELEASE 重点介绍 本次实战有几处重点需要注意: spring-kafkakafka的版本匹配问题,请关注官方文档:https://spring.io/projects/spring-kafka kafkakafka的advertised

    作者: 程序员欣宸
    发表时间: 2022-07-25 15:59:00
    501
    0
  • Kafka_2.11-1.1.1移植指南★★☆

    html5 Kafka编译下载kafka源码并解压:wget https://archive.apache.org/dist/kafka/1.1.1/   kafka-1.1.1-src.tgztar   -zxf kafka-1.1.1-src.tgzcd kafka-1.1.1

    作者: 东南西北@南屏晚钟
    2628
    0
  • RocketMQ与Kafka实践上对比

    化,2011年初,Linkin开源了Kafka这个优秀的消息中间件,淘宝中间件团队在对Kafka做过充分Review之后,Kafka无限消息堆积,高效的持久化速度吸引了我们,但是同时发现这个消息系统主要定位于日志传输,对于使用在淘宝交易、订单、充值等场景下还有诸多特性不满足,为此

    作者: 林欣
    19
    0
  • 分布式消息服务Kafka版 - 分布式消息服务Kafka版

    先购买Kafka实例。Kafka实例采用物理隔离的方式部署,租户独占Kafka实例。 支持区域: 全部 购买Kafka实例 连接Kafka 开源Kafka客户端向Kafka实例生产消息和消费消息前,需要先连接Kafka实例。 创建Kafka实例时,支持开启或者关闭SASL_SSL