更新时间:2022-02-21 GMT+08:00

创建工程

本章节以新建名为“kafkademo”的Maven Project为例。

操作步骤

  1. 下载Demo包。

    1. 登录DMS服务管理控制台。
    2. 在左侧导航栏选择“API使用向导”。
    3. 选择“Kafka普通版”。
    4. 单击“示例代码下载”。下载DmsKafkaDemo.zip压缩包,即为Demo包。

  2. 单击“SDK下载”,下载SDK包,即DMS Kafka sasl包。

    下载后解压,目录如下:

    • client.truststore.jks:客户端证书
    • dms.kafka.sasl.client-1.0.0.jar: SASL包
    • dms_kafka_client_jaas.conf:客户端配置文件

    也可以从Demo包中获取DMS Kafka sasl包,获取地址:\DmsKafkaDemo\dist\libs\dms.kafka.sasl.client-1.0.0.jar。

  3. 打开Eclipse,建议使用4.6以上版本,新建一个Maven Project,工程名自定义,这里以kafkademo为例。

    图1 新建Maven Project

  4. 单击“Finish”。
  5. 导入DMS Kafka sasl的jar包。

    1. 右键单击新建的工程“kafkademo”,新建一个Folder,命名为libs。
    2. 将dms.kafka.sasl.client-1.0.0.jar复制到libs目录下。
    3. 在pom.xml文件中增加如下行,将DMS Kafka sasl的jar包导入Maven仓库。
      <dependency> 
           <groupId>dms</groupId> 
           <artifactId>kafka.sasl.client</artifactId> 
           <version>1.0.0</version> 
           <scope>system</scope> 
           <systemPath>${project.basedir}/libs/dms.kafka.sasl.client-1.0.0.jar</systemPath> 
       </dependency> 
       <dependency> 
           <groupId>org.apache.kafka</groupId> 
           <artifactId>kafka-clients</artifactId> 
           <version>0.10.2.1</version> 
       </dependency> 
       <dependency> 
           <groupId>org.slf4j</groupId> 
           <artifactId>slf4j-api</artifactId> 
           <version>1.7.7</version> 
       </dependency> 
       <dependency> 
           <groupId>org.slf4j</groupId> 
           <artifactId>slf4j-log4j12</artifactId> 
           <version>1.7.7</version> 
       </dependency> 
       <dependency> 
           <groupId>log4j</groupId> 
           <artifactId>log4j</artifactId> 
           <version>1.2.17</version> 
       </dependency>     
    4. 保存“pom.xml”。