-
设置Kafka Topic权限 - 分布式消息服务Kafka版
能订阅/发布此Topic。“allow.everyone.if.no.acl.found”在配置参数中修改。 如果Topic已授权某一个或多个用户,此时只有授权的用户可以订阅/发布此Topic,其他未授权的用户不能订阅/发布此Topic。 如果Topic同时设置了“默认用户”权限和单个用户权限,取两者的并集。
-
Java开发环境搭建 - 分布式消息服务Kafka版
”时,配置信息如下。 security.protocol=SASL_PLAINTEXT 在IDEA工具的左下角,打开Terminal窗口,执行mvn test命令体验demo。 图4 IDEA的Terminal窗口位置 生产消息会得到以下回显信息: ---------------
-
配置Kafka自动创建Topic - 分布式消息服务Kafka版
体以控制台显示为准。 单击“确认”,完成“Kafka自动创建Topic”的开启/关闭。 您可以在“后台任务管理”页面,查看开启/关闭任务的执行状态。 父主题: Topic管理
-
欠费说明 - 分布式消息服务Kafka版
总览”的“欠费金额”中查看,华为云将在您充值时自动扣取欠费金额。 如果您在宽限期内仍未支付欠款,那么就会进入保留期,资源状态变为“已冻结”,您将无法对处于保留期的按需计费资源执行任何操作。 保留期到期后,若您仍未支付账户欠款,那么Kafka实例将被释放,数据无法恢复。 图1 按需计费Kafka实例生命周期 华为云根
-
配置Kafka监控告警 - 分布式消息服务Kafka版
该指标用于统计Kafka实例中已经使用的分区数量。 出现该告警时,如果业务后续还需要新增Topic,则需要修改实例基准带宽/代理个数或将业务拆分至多个实例。修改实例基准带宽/代理个数的具体操作,请参考变更实例规格。 broker_cpu_usage CPU使用率 节点 告警阈值:原始值>90%
-
Python - 分布式消息服务Kafka版
information. >>> 如果未安装Python,请使用以下命令安装: yum install python Python版的Kafka客户端 执行以下命令,安装推荐版本的kafka-python: pip install kafka-python==2.0.1 生产消息 以下加粗内容
-
创建用户并授权使用DMS for Kafka - 分布式消息服务Kafka版
除实例的自定义策略,然后同时将DMS FullAccess和拒绝策略授予用户,根据Deny优先原则,则用户可以对DMS for Kafka执行除了删除实例外的所有操作。拒绝策略示例如下: { "Version": "1.1", "Statement":
-
创建Kafka实例 - 分布式消息服务Kafka版
Kafka实例规格为1200MB时,公网带宽取值范围8到2400,且必须为实例节点个数的倍数。 publicip_id String 否 实例绑定的弹性IP地址的ID。 以英文逗号隔开多个弹性IP地址的ID。 如果开启了公网访问功能(即enable_publicip为true),该字段为必选。 ssl_enable Boolean
-
Kafka客户端参数配置建议 - 分布式消息服务Kafka版
以减少请求次数。这将改善client与server之间的性能。不会试图处理大于这个字节数的消息字节数。 发送到brokers的请求将包含多个批量处理,其中会包含对每个partition的一个请求。 较小的批量处理数值比较少用,并且可能降低吞吐量(0则会仅用批量处理)。较大的批量
-
配置Kafka实例标签 - 分布式消息服务Kafka版
分布式消息服务Kafka版”,进入分布式消息服务Kafka专享版页面。 在实例所在行,单击实例名称,进入实例详情页面。 在左侧导航栏单击“标签”,进入标签管理页面。 界面显示该实例的标签列表。 您可以根据实际需要,执行以下操作: 添加标签 单击“创建/删除标签”,弹出“创建/删除标签”对话框。
-
配置Kafka用户 - 分布式消息服务Kafka版
单击Kafka实例名称,进入实例详情页面。 通过以下任意一种方法,删除用户。 在“用户管理”页面,在待删除的用户所在行,单击“删除”。 在“用户管理”页面,勾选用户名左侧的方框,可选一个或多个,单击信息栏左上侧的“删除”。 首次开启密文接入时设置的用户无法删除。 在弹出的“删除用户”对话框中,单击“确定”,完成用户的删除。
-
管理Smart Connect任务 - 分布式消息服务Kafka版
Connect”,进入Smart Connect任务列表页面。 执行以下操作,启动/暂停Smart Connect任务。 启动:在待启动的Smart Connect任务所在行,单击“启动”。 暂停:在待暂停的Smart Connect任务所在行,单击“暂停”,弹出“暂停任务”对话框,单击“确定”。
-
修改Kafka实例配置参数 - 分布式消息服务Kafka版
致broker被抢占更多的资源。 6000 ~ 300000 6000 如果需要批量修改参数,单击“批量编辑”,可以一次性编辑多个动态参数或静态参数的运行值。 如果需要恢复默认值,在待修改参数后,单击“恢复默认”。 单击“保存”,完成参数的修改。 动态参数修改成功后,无需重启实例
-
Java客户端接入示例 - 分布式消息服务Kafka版
data = "The msg is " + i; // 注意填写您创建的topic名称。另外,生产消息的API有多个,具体参见Kafka官网或者下文的生产消息代码。 producer.produce("topic-0", partition
-
关闭Kafka Manager - 分布式消息服务Kafka版
更多编程语言的SDK代码示例,请参见API Explorer的代码示例页签,可生成自动对应的SDK代码示例。 状态码 状态码 描述 200 执行成功 错误码 请参见错误码。 父主题: 实例管理
-
按需计费 - 分布式消息服务Kafka版
宽限期内未支付欠款,资源进入保留期 如果您在宽限期内仍未支付欠款,那么就会进入保留期,资源状态变为“已冻结”,您将无法对处于保留期的按需计费资源执行任何操作。 保留期内未支付欠款,资源释放且无法恢复 保留期到期后,若您仍未支付账户欠款,那么Kafka实例将被释放,数据无法恢复。 华为云
-
重启Manager - 分布式消息服务Kafka版
String 实例ID。 请求参数 无 响应参数 状态码: 200 表2 响应Body参数 参数 参数类型 描述 result String 执行结果。 instance_id String 实例ID。 请求示例 重启Kafka Manager。 PUT https://{endpo
-
关闭Smart Connect(按需实例) - 分布式消息服务Kafka版
String 实例ID。 请求参数 无 响应参数 状态码: 200 表2 响应Body参数 参数 参数类型 描述 job_id String 返回异步执行删除任务的job id。 请求示例 POST https://{endpoint}/v2/{project_id}/kafka/insta
-
实例扩容 - 分布式消息服务Kafka版
publicip_id 否 String 实例绑定的弹性IP地址的ID。 以英文逗号隔开多个弹性IP地址的ID。 当oper_type类型是horizontal时,该参数必填。 tenant_ips 否 Array of strings 指定的内网IP地址,仅支持指定IPv4。 指定的IP数量只能小于等于新增节点数量。
-
包年/包月 - 分布式消息服务Kafka版
如果您在宽限期内仍未续费包年/包月Kafka实例,Kafka实例会进入保留期,Kafka实例状态变为“已冻结”,您将无法对处于保留期的包年/包月Kafka实例执行任何操作。 资源保留期到期未续费,释放且不可恢复 如果包年/包月Kafka实例在保留期到期前仍未续费,那么Kafka实例将被释放,数据无法恢复。