Merge branch 'master' of http://10.1.235.20:3000/rest/code-example.git

ipu-db-example/pom.xml

@@ -0,0 +1,30 @@
<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>
    <groupId>com.ai.ipu</groupId>
    <artifactId>ipu-db-example</artifactId>
    <version>1.0-SNAPSHOT</version>
    <properties>
        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
        <ipu>3.1-SNAPSHOT</ipu>
        <jdk>1.8</jdk>
    </properties>
    <dependencies>
        <dependency>
            <groupId>com.ai.ipu</groupId>
            <artifactId>ipu-database</artifactId>
            <version>${ipu}</version>
        </dependency>
        <dependency>
            <groupId>com.ai.ipu</groupId>
            <artifactId>ipu-sql-mgmt</artifactId>
            <version>${ipu}</version>
        </dependency>
    </dependencies>
</project>

ipu-kafka-example/src/main/java/com/ai/ipu/example/kafka/KafkaCustomer.java

@@ -1,5 +1,6 @@
package com.ai.ipu.example.kafka;
import com.ai.aif.msgframe.consumer.MfConsumerClient;
import com.ai.aif.msgframe.consumer.MfServiceStartup;
/**
@@ -10,6 +11,9 @@ import com.ai.aif.msgframe.consumer.MfServiceStartup;
 */
public class KafkaCustomer {
    public static void main(String[] args){
        MfServiceStartup.main();
        //全部启动
//        MfServiceStartup.main();
        //启动某一个topic(还是需要与msgframe-config.xml中对应)
        MfConsumerClient.subscribe("test", "*",	"com.ai.ipu.example.kafka.KafkaCustomerExample");
    }
}

ipu-kafka-example/src/main/resources/msgframe-config.xml

@@ -18,11 +18,5 @@
                <url>47.105.160.21:9091,47.105.160.21:9092,47.105.160.21:9093</url>
            </cluster>
        </clusters>
        <!--<persistence>-->
            <!--<exceptionPersistence>-->
                <!--<producerExceptionClass>com.ai.ipu.example.kafka.exception.ProducerExceprionHandle</producerExceptionClass>-->
                <!--<consumerExceptionClass>com.ai.ipu.example.kafka.exception.ConsumerExceprionHandle</consumerExceptionClass>-->
            <!--</exceptionPersistence>-->
        <!--</persistence>-->
    </centerCfg>
</msgframeCfg>