-
在Windows服务器中无法登录Kafka Manager - 分布式消息服务Kafka版
在Windows服务器中无法登录Kafka Manager 问题现象 在Windows服务器的浏览器中输入Kafka Manager地址,无法登录Kafka Manager,报错信息如下图。
-
Kafka服务和ZK是部署在相同的虚拟机中,还是分开部署? - 分布式消息服务Kafka版
Kafka服务和ZK是部署在相同的虚拟机中,还是分开部署? Kafka服务和ZK部署在相同的虚拟机中。 父主题: 实例问题
-
查询Kafka实例的协调器信息 - 分布式消息服务Kafka版
查询Kafka实例的协调器信息 功能介绍 查询Kafka实例的协调器信息。 调用方法 请参见如何调用API。
-
扩容失败提示资源不足 - 分布式消息服务Kafka版
扩容失败提示资源不足 问题现象:扩容失败,提示底层ECS/EVS资源不足,但在ECS控制台可以购买对应规格的ECS。 可能原因:底层资源配额与控制台界面显示的可用规格配额存在差异。 解决方法:联系客服增加配额数。 父主题: 实例规格变更问题
-
使用客户端连接Kafka(密文接入) - 分布式消息服务Kafka版
已创建开启弹性公网IP的弹性云服务器,如果使用内网通过同一个VPC访问实例,请设置弹性云服务器的VPC、子网、安全组与Kafka实例的VPC、子网、安全组一致。
-
Logstash对接Kafka生产消费消息 - 分布式消息服务Kafka版
Logstash对接Kafka生产消费消息 应用场景 Logstash是免费且开放的服务器端数据处理管道,能够从多个来源采集数据,转换数据,然后将数据发送到指定的存储中。Kafka是一种高吞吐量的分布式发布订阅消息系统,也是Logstash支持的众多输入输出源之一。
-
状态码 - 分布式消息服务Kafka版
413 Request Entity Too Large 由于请求的实体过大,服务器无法处理,因此拒绝请求。为防止客户端的连续请求,服务器可能会关闭连接。如果只是服务器暂时无法处理,则会包含一个Retry-After的响应信息。
-
配置Kafka的SSL双向认证 - 分布式消息服务Kafka版
前提条件 已准备一台Linux系统的服务器。 实例已开启Kafka SASL_SSL。 配置SSL双向认证流程 图1 配置SSL双向认证流程图 步骤一:制作客户端验证服务端的证书 登录Linux系统的服务器,执行以下命令,生成server.keystore.jks证书的孵化器。
-
查询Kafka实例所有消费组对应的协调器信息 - 分布式消息服务Kafka版
查询Kafka实例所有消费组对应的协调器信息 当前页面API为历史版本API,未来可能停止维护。请使用查询Kafka实例的协调器信息。
-
选择和配置安全组 - 分布式消息服务Kafka版
是,如果保留了创建安全组后,系统默认添加的入方向“允许安全组内的弹性云服务器彼此通信”规则和出方向“放通全部流量”规则,则无需添加其他规则。否则,请添加表1所示规则。
-
Kafka Manager概述 - 分布式消息服务Kafka版
登录Kafka Manager 创建一台与Kafka实例相同VPC和相同安全组的Windows服务器,详细步骤请参考购买并登录Windows弹性云服务器。 如果是已经开启了公网访问,该步骤为可选,在本地浏览器中即可访问,不需要单独的Windows弹性云服务器。
-
制作和替换Kafka的SSL证书 - 分布式消息服务Kafka版
执行以下命令,为服务器证书签名。 导出服务器证书“server.cert-file”。
-
与其他云服务的关系 - 分布式消息服务Kafka版
弹性云服务器(Elastic Cloud Server) 弹性云服务器是由CPU、内存、操作系统、云硬盘组成的基础的计算组件。Kafka实例运行在弹性云服务器上,一个代理对应一台弹性云服务器。
-
测试Kafka生产速率和CPU消耗 - 分布式消息服务Kafka版
购买客户端服务器。 购买如下参数的2台ECS服务器,具体步骤请参考购买弹性云服务器。 区域、可用区、虚拟私有云、子网、安全组与Kafka实例保持一致,规格为4U8G,Linux系统的ECS。
-
构造请求 - 分布式消息服务Kafka版
GET:请求服务器返回指定资源。 PUT:请求服务器更新指定资源。 POST:请求服务器新增资源或执行特殊操作。 DELETE:请求服务器删除指定资源,如删除对象等。 HEAD:请求服务器资源头部。 PATCH:请求服务器更新资源的部分内容。
-
使用MirrorMaker跨集群同步数据 - 分布式消息服务Kafka版
实施步骤 购买一台弹性云服务器,确保弹性云服务器与源集群、目标集群网络互通。具体购买操作,请参考购买弹性云服务器。 登录弹性云服务器,安装Java JDK,并配置JAVA_HOME与PATH环境变量,使用执行用户在用户家目录下修改“.bash_profile”,添加如下行。
-
业务过载处理建议 - 分布式消息服务Kafka版
当CPU使用率过高时,系统的运行速度会降低,并有加速硬件损坏的风险。 当磁盘写满时,相应磁盘上的Kafka日志目录会出现offline问题。此时,该磁盘上的分区副本不可读写,降低了分区的可用性和容错能力。同时由于Leader分区迁移到其他节点,会增加其他节点的负载。
-
快速连接Kafka并生产消费消息 - 分布式消息服务Kafka版
本文以Linux系统的ECS为例,Windows系统ECS的JDK安装与环境变量配置可自行在互联网查找相关帮助。 登录管理控制台,在左上角单击,选择“计算 > 弹性云服务器”,创建一个ECS实例。 创建ECS的操作步骤,请参考购买弹性云服务器。
-
Kafka相关概念 - 分布式消息服务Kafka版
代理(Broker) 即Kafka集群架构设计中的单个Kafka进程,一个Kafka进程对应一台服务器,因此手册中描述的代理,还包括对应的存储、带宽等服务器资源。
-
Python - 分布式消息服务Kafka版
[root@ecs-test python-kafka]# python3 Python 3.7.1 (default, Jul 5 2020, 14:37:24) [GCC 4.8.5 20150623 (Red Hat 4.8.5-39)] on linux Type "help