![]()
查看Kafka磁盘使用量 本章节指导您在控制台查看每个代理上磁盘的使用量，以了解Kafka实例的磁盘使用情况。 约束与限制 单机实例不支持查看磁盘使用量。 查看Kafka磁盘使用量 登录Kafka控制台。 在管理控制台左上角单击，选择Kafka实例所在的区域。 单击Kafka实例的名称，进入实例的“概览”页面。
来自：帮助中心![]()
Kafka客户端使用建议 consumer使用建议 consumer的owner线程需确保不会异常退出，避免客户端无法发起消费请求，阻塞消费。 确保处理完消息后再做消息commit，避免业务消息处理失败，无法重新拉取处理失败的消息。 通常不建议对每条消息都进行commit，如果对
来自：帮助中心![]()
执行以下命令切换到Kafka客户端安装目录。 cd Kafka/kafka/bin 执行以下命令使用客户端工具查看帮助并使用。 ./kafka-console-consumer.sh：Kafka消息读取工具 ./kafka-console-producer.sh：Kafka消息发布工具
来自：帮助中心![]()
请参见如何调用API。 授权信息 账号具备所有API的调用权限，如果使用账号下的IAM用户调用当前API，该IAM用户需具备调用API所需的权限。 如果使用角色与策略授权，具体权限要求请参见权限和授权项。 如果使用身份策略授权，需具备如下身份策略权限。 授权项 访问级别 资源类型（*为必须）
来自：帮助中心![]()
请参见如何调用API。 授权信息 账号具备所有API的调用权限，如果使用账号下的IAM用户调用当前API，该IAM用户需具备调用API所需的权限。 如果使用角色与策略授权，具体权限要求请参见权限和授权项。 如果使用身份策略授权，需具备如下身份策略权限。 授权项 访问级别 资源类型（*为必须）
来自：帮助中心![]()
请参见如何调用API。 授权信息 账号具备所有API的调用权限，如果使用账号下的IAM用户调用当前API，该IAM用户需具备调用API所需的权限。 如果使用角色与策略授权，具体权限要求请参见权限和授权项。 如果使用身份策略授权，需具备如下身份策略权限。 授权项 访问级别 资源类型（*为必须）
来自：帮助中心![]()
请参见如何调用API。 授权信息 账号具备所有API的调用权限，如果使用账号下的IAM用户调用当前API，该IAM用户需具备调用API所需的权限。 如果使用角色与策略授权，具体权限要求请参见权限和授权项。 如果使用身份策略授权，需具备如下身份策略权限。 授权项 访问级别 资源类型（*为必须）
来自：帮助中心![]()
请参见如何调用API。 授权信息 账号具备所有API的调用权限，如果使用账号下的IAM用户调用当前API，该IAM用户需具备调用API所需的权限。 如果使用角色与策略授权，具体权限要求请参见权限和授权项。 如果使用身份策略授权，需具备如下身份策略权限。 授权项 访问级别 资源类型（*为必须）
来自：帮助中心![]()
FangBo 数据规划 Spark Streaming样例工程的数据存储在Kafka组件中。向Kafka组件发送数据（需要有Kafka权限用户）。 确保集群安装完成，包括HDFS、Yarn、Spark和Kafka。 本地新建文件“input_data1.txt”，将“log1.txt
来自：帮助中心![]()
![]()
![]()
请参见如何调用API。 授权信息 账号具备所有API的调用权限，如果使用账号下的IAM用户调用当前API，该IAM用户需具备调用API所需的权限。 如果使用角色与策略授权，具体权限要求请参见权限和授权项。 如果使用身份策略授权，当前API调用无需身份策略权限。 URI GET /v2/config/features
来自：帮助中心![]()
请参见如何调用API。 授权信息 账号具备所有API的调用权限，如果使用账号下的IAM用户调用当前API，该IAM用户需具备调用API所需的权限。 如果使用角色与策略授权，具体权限要求请参见权限和授权项。 如果使用身份策略授权，需具备如下身份策略权限。 授权项 访问级别 资源类型（*为必须）
来自：帮助中心![]()
使用控制台连接Kafka 本章节介绍Kafka实例如何在控制台生产消息。此功能通过将指定消息发送给Kafka实例，验证业务逻辑是否正常。 前提条件 仅在实例的“状态”为“运行中”时，才可以在Topic中生产消息。 已创建Topic。 在控制台生产消息 登录Kafka控制台。 在管
来自：帮助中心![]()
当前Kafka实例别名。（仅源端类型为Kafka时会显示） 取值范围： 不涉及。 cluster_name 否 String 参数解释： 对端Kafka实例别名。（仅源端类型为Kafka时会显示） 取值范围： 不涉及。 user_name 否 String 参数解释： 对端Kafka用户名。（仅源端类型为Kafka时会显示）
来自：帮助中心![]()
获取Kafka实例扩容前置检查信息 - ShowKafkaScalePreCheckInfo 功能介绍 获取Kafka实例扩容前置检查信息。 调用方法 请参见如何调用API。 授权信息 账号具备所有API的调用权限，如果使用账号下的IAM用户调用当前API，该IAM用户需具备调用API所需的权限。
来自：帮助中心![]()
请参见如何调用API。 授权信息 账号具备所有API的调用权限，如果使用账号下的IAM用户调用当前API，该IAM用户需具备调用API所需的权限。 如果使用角色与策略授权，具体权限要求请参见权限和授权项。 如果使用身份策略授权，需具备如下身份策略权限。 授权项 访问级别 资源类型（*为必须）
来自：帮助中心![]()
请参见如何调用API。 授权信息 账号具备所有API的调用权限，如果使用账号下的IAM用户调用当前API，该IAM用户需具备调用API所需的权限。 如果使用角色与策略授权，具体权限要求请参见权限和授权项。 如果使用身份策略授权，需具备如下身份策略权限。 授权项 访问级别 资源类型（*为必须）
来自：帮助中心![]()
请参见如何调用API。 授权信息 账号具备所有API的调用权限，如果使用账号下的IAM用户调用当前API，该IAM用户需具备调用API所需的权限。 如果使用角色与策略授权，具体权限要求请参见权限和授权项。 如果使用身份策略授权，需具备如下身份策略权限。 授权项 访问级别 资源类型（*为必须）
来自：帮助中心
