package com.qxueyou.scc.sys.msg; import org.apache.kafka.clients.consumer.ConsumerRecord; import org.springframework.kafka.listener.MessageListener; public interface ICustomerMsgConsumerService extends MessageListener { void onMessage(ConsumerRecord data); void doCreateVideoLivePlaybackByMsg(ConsumerRecord data); }