KafkaMessageProcess.java

package com.dataspy.common.process;

import com.dataspy.common.bean.ProcessResult;
import org.apache.kafka.clients.consumer.ConsumerRecord;

import java.util.List;
import java.util.concurrent.Future;

public interface KafkaMessageProcess {
    /**
     *
     * @param recordList 从kafka接收到的数据
     * @return
     */
    Future<ProcessResult> process(List<ConsumerRecord<String,String>> recordList,String uid);

}