package com.yougou.order.kafka.dto;
import java.io.Serializable;
/**
* kafka数据传输对象
* 适用范围,自产自消,与外部系统交互均按此格式
*
* @param <T>
* @author liuwei
*/
public class KafkaDto<T> implements Serializable {
private static final long serialVersionUID = 1L;
/**
* 消息ID
*/
private String msgId;
/**
* 业务数据对象
*/
private T data;
public String getMsgId() {
return msgId;
}
public void setMsgId(String msgId) {
this.msgId = msgId;
}
public T getData() {
return data;
}
public void setData(T data) {
this.data = data;
}
@Override
public String toString() {
final StringBuffer sb = new StringBuffer("KafkaDto{");
sb.append("msgId='").append(msgId).append('\'');
sb.append(", data=").append(data);
sb.append('}');
return sb.toString();
}
}