1. package com.yougou.order.kafka.dto;
    2. import java.io.Serializable;
    3. /**
    4. * kafka数据传输对象
    5. * 适用范围,自产自消,与外部系统交互均按此格式
    6. *
    7. * @param <T>
    8. * @author liuwei
    9. */
    10. public class KafkaDto<T> implements Serializable {
    11. private static final long serialVersionUID = 1L;
    12. /**
    13. * 消息ID
    14. */
    15. private String msgId;
    16. /**
    17. * 业务数据对象
    18. */
    19. private T data;
    20. public String getMsgId() {
    21. return msgId;
    22. }
    23. public void setMsgId(String msgId) {
    24. this.msgId = msgId;
    25. }
    26. public T getData() {
    27. return data;
    28. }
    29. public void setData(T data) {
    30. this.data = data;
    31. }
    32. @Override
    33. public String toString() {
    34. final StringBuffer sb = new StringBuffer("KafkaDto{");
    35. sb.append("msgId='").append(msgId).append('\'');
    36. sb.append(", data=").append(data);
    37. sb.append('}');
    38. return sb.toString();
    39. }
    40. }