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