云服务器内容精选

华为云首页用户手册

配置Topic

分布式消息服务KAFKA版-设置Kafka Topic权限:约束与限制

约束与限制如果“allow.everyone.if.no.acl.found”设置为“true”，且Topic未授权任何用户，此时所有的用户都可以订阅/发布此Topic。如果Topic已授权某一个或多个用户，此时只有授权的用户可以订阅/发布此Topic，其他未授权的用户不能订阅/发布此Topic。“allow.everyone.if.no.acl.found”在配置参数中修改。如果“allow.everyone.if.no.acl.found”设置为“false”，此时只有授权的用户可以订阅/发布此Topic，其他未授权的用户不能订阅/发布此Topic。“allow.everyone.if.no.acl.found”在配置参数中修改。如果Topic同时设置了“默认用户”权限和单个用户权限，取两者的并集。

分布式消息服务KAFKA版配置Topic
分布式消息服务KAFKA版-创建Kafka Topic:方式3：在Kafka客户端上创建Topic

方式3：在Kafka客户端上创建Topic Kafka客户端版本为2.2以上时，支持通过kafka-topics.sh创建Topic，以及管理Topic的各类参数。 Topic名称开头包含特殊字符，例如#号“#”时，监控数据无法展示。已开启密文接入的实例，“allow.everyone.if.no.acl.found”设置为“false”时，无法通过客户端创建Topic。未开启密文接入的Kafka实例，在Kafka客户端的“/bin”目录下，通过以下命令创建Topic。 ./kafka-topics.sh --create --topic ${topic-name} --bootstrap-server ${connection-address} --partitions ${number-of-partitions} --replication-factor ${number-of-replicas} 已开启密文接入的Kafka实例，通过以下步骤创建Topic。（可选）Kafka安全协议为“SASL_PLAINTEXT”还是“SASL_SSL”？ SASL_PLAINTEXT：如果已经设置了用户名和密码，请跳过此步骤。否则在Kafka客户端的“/config”目录中创建“ssl-user-config.properties”文件，参考3增加用户名和密码。 SASL_SSL：如果已经设置了用户名和密码，以及SSL证书配置，请跳过此步骤。否则在Kafka客户端的“/config”目录中创建“ssl-user-config.properties”文件，参考3增加用户名和密码，以及SSL证书配置。在Kafka客户端的“/bin”目录下，通过以下命令创建Topic。 ./kafka-topics.sh --create --topic ${topic-name} --bootstrap-server ${connection-address} --partitions ${number-of-partitions} --replication-factor ${number-of-replicas} --command-config ./config/ssl-user-config.properties

分布式消息服务KAFKA版配置Topic