MAPREDUCE服务 MRS-Kafka应用开发规则:调用Kafka API（AdminZkClient.createTopic）创建Topic

时间：2024-05-28 14:22:56

MAPREDUCE服务 MRS

调用Kafka API（AdminZkClient.createTopic）创建Topic

对于Java开发语言，正确示例：

import kafka.zk.AdminZkClient;
import kafka.zk.KafkaZkClient;
import kafka.admin.RackAwareMode;
… 
KafkaZkClient kafkaZkClient = KafkaZkClient.apply(zkUrl, JaasUtils.isZkSecurityEnabled(), zkSessionTimeoutMs, zkConnectionTimeoutMs, Int.MaxValue(), Time.SYSTEM, "", "", null);
AdminZkClient adminZkClient = new AdminZkClient(kafkaZkClient);
adminZkClient.createTopic(topic, partitions, replicas, new Properties(), RackAwareMode.Enforced$.MODULE$);
…

对于Scala开发语言，正确示例：

import kafka.zk.AdminZkClient;
import kafka.zk.KafkaZkClient;
… 
val kafkaZkClient: KafkaZkClient = KafkaZkClient.apply(zkUrl, JaasUtils.isZkSecurityEnabled(), zkSessionTimeoutMs, zkConnectionTimeoutMs, Int.MaxValue, Time.SYSTEM, "", "")
val adminZkClient: AdminZkClient = new AdminZkClient(kafkaZkClient)
adminZkClient.createTopic(topic, partitions, replicas)

上一篇：MAPREDUCE服务 MRS-HDFS应用开发建议:HDFS的读写文件注意点

下一篇：MAPREDUCE服务 MRS-Doris数据查询规范:Doris数据查询规则