更新时间:2022-02-21 GMT+08:00
创建工程
本章节以新建名为“kafkademo”的Maven Project为例。
操作步骤
- 下载Demo包。
- 登录DMS服务管理控制台。
- 在左侧导航栏选择“API使用向导”。
- 选择“Kafka普通版”。
- 单击“示例代码下载”。下载DmsKafkaDemo.zip压缩包,即为Demo包。
- 单击“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。
- 打开Eclipse,建议使用4.6以上版本,新建一个Maven Project,工程名自定义,这里以kafkademo为例。
图1 新建Maven Project
- 单击“Finish”。
- 导入DMS Kafka sasl的jar包。
- 右键单击新建的工程“kafkademo”,新建一个Folder,命名为libs。
- 将dms.kafka.sasl.client-1.0.0.jar复制到libs目录下。
- 在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>
- 保存“pom.xml”。
父主题: Java SDK