wuxw
2019-02-02 9454b49eeabd56894550f1419f14e96f9d10c2ef
AgentService/src/main/java/com/java110/agent/kafka/AgentServiceKafka.java
@@ -12,6 +12,8 @@
import com.java110.core.factory.DataTransactionFactory;
import com.java110.agent.smo.IAgentServiceSMO;
import org.apache.kafka.clients.consumer.ConsumerRecord;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.kafka.annotation.KafkaListener;
@@ -24,6 +26,8 @@
 */
public class AgentServiceKafka extends BaseController {
    private final static Logger logger = LoggerFactory.getLogger(AgentServiceKafka.class);
    @Autowired
    private IAgentServiceSMO agentServiceSMOImpl;