package com.qxueyou.scc.sys.msg;

import org.apache.kafka.clients.consumer.ConsumerRecord;
import org.springframework.stereotype.Component;

@Component
public class CustomMsgConsumerService implements ICustomerMsgConsumerService {

	@Override
	public void doCreateVideoLivePlaybackByMsg(ConsumerRecord<String,String> data) {
		System.out.println("doCreateVideoLivePlaybackByMsg:"+data.value());
	}

	@Override
	public void onMessage(ConsumerRecord<String,String> data) {
		 System.out.println("received: " + data);
		 doCreateVideoLivePlaybackByMsg(data);
	}
	
	
	
	
}