检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
您只需要在实例管理界面选好规格配置，提交订单。后台将自动创建部署完成一整套Kafka实例。 兼容开源，业务零改动迁移上云 兼容社区版Kafka的API，具备原生Kafka的所有消息处理特性。 业务系统基于开源的Kafka进行开发，只需加入少量认证安全配置，即可使用分布式消息服务Kafka版，做到无缝迁移。
针对DMS for Kafka服务，管理员能够控制IAM用户仅能对实例进行指定的管理操作。多数细粒度策略以API接口为粒度进行权限拆分，DMS for Kafka支持的API授权项请参见细粒度策略支持的授权项。 如表1所示，包括了DMS for Kafka的所有系统权限。 表1 DMS
/bin/logstash -f ./config/output.conf 返回“Successfully started Logstash API endpoint”时，表示启动成功。 图4 启动Logstash 在Logstash中，生产消息，如下图所示。 图5 生产消息 切换到K
data = "The msg is " + i; // 注意填写您创建的topic名称。另外，生产消息的API有多个，具体参见Kafka官网或者下文的生产消息代码。 producer.produce("topic-0"
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
