msgframe的kafka测试代码

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

package com.ai.ipu.example.kafka;
import com.ai.aif.msgframe.consumer.MfConsumerClient;
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

                <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>