检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
发送消息后，生产者需要根据分布式消息服务Kafka版的返回信息确认消息是否发送成功，如果返回失败需要重新发送。 生产消息时，生产者通过同步等待发送结果或异步回调函数，判断消息是否发送成功。在消息传递过程中，如果发生异常，生产者没有接收到发送成功的信号，生产者自己决策是否需要重复发送消息。
选择“综合推荐”中的“入门版”。入门版面向入门级用户，提供兼容开源协议的托管Kafka服务，适用于性能诉求不高、时延容忍度较高的成本敏感业务或测试环境等。 单个代理存储空间 根据实际需要选择存储Kafka数据的磁盘类型和磁盘大小。 实例总存储空间 = 单个代理的存储空间 * 代理数量
者长时间没有与服务端通信导致，比如处理消息耗时太久阻塞等。 对文件中每次Preparing到Stabilized完成的时间进行计算得到以下结果图。图中时间为UTC+0时间，对应北京时间需要加8小时。 图1 消费组rebalance图 从以上图中可以看出，消费组rebalance的
v2：使用高IO的磁盘类型。 dms.physical.storage.ultra.v2：使用超高IO的磁盘类型。 如何选择磁盘类型请参考《云硬盘 产品介绍》的“磁盘类型及性能介绍”。 enterprise_project_id 否 String 企业项目ID。若为企业项目账号，该参数必填。
group_desc 否 String 消费组描述 响应参数 状态码：200 表3 响应Body参数 参数 参数类型 描述 - String 创建结果 状态码：400 表4 响应Body参数 参数 参数类型 描述 error_code String 错误码。 error_msg String
String 实例ID。 请求参数 无 响应参数 状态码：200 表2 响应Body参数 参数 参数类型 描述 result String 执行结果。 instance_id String 实例ID。 请求示例 重启Kafka Manager。 PUT https://{endpoin
KafkaMessageDiagnosisItemEntity 参数 参数类型 描述 name String 诊断项名称 result String 诊断结果 cause_ids Array of KafkaMessageDiagnosisConclusionEntity objects 诊断异常原因列表
参数 参数类型 描述 results Array of results objects 修改实例的结果。 表4 results 参数 参数类型 描述 result String 操作结果。 success: 操作成功 failed: 操作失败 instance String 实例ID。
只能查询Python 2.x版本，python3命令只能查询Python 3.x版本，如果无法确认Python版本，请分别输入两个命令查看结果。 以Python 3.x为例，得到如下回显，说明Python已安装。 [root@ecs-test python-kafka]# python3
Happened when poll records: " + e); } } } } 代码示例运行结果 [2018-01-25 22:40:51,841] INFO Thread 2 Polling! (com.huawei.dms.kafka
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
