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);
|
}
|
|
|
|
|
}
|
