项目准备.html

创建测试Maven项目： 在项目中的pom.xml文件添加如下配置：

1.导入依赖Maven pom文件

        <dependency>
            <groupId>org.apache.thrift</groupId>
            <artifactId>libthrift</artifactId>
            <version>0.11.0</version>
        </dependency>

2.导入客户端类文件：

com.dksou.fitting.stream.service.DKStreamProducerService.java
com.dksou.fitting.stream.service.JavaKafkaConsumerHighAPIESService.java
com.dksou.fitting.stream.service.JavaKafkaConsumerHighAPIHdfsService.java