package com.twjitm.core.common.kafka;

/**
 * @author twjitm - [Created on 2018-09-04 21:31]
 * @company https://github.com/twjitm/
 * @jdk java version "1.8.0_77"
 */
public abstract class AbstractKafkaPushTask {
    private KafkaTaskType taskType;
    public Object value;

    public AbstractKafkaPushTask(KafkaTaskType taskType) {
        this.taskType = taskType;
    }

    public KafkaTaskType getTaskType() {
        return taskType;
    }


    public Object getValue() {
        return value;
    }

    /**
     * 需要将消息值保存到这里面，值如何获得由子类自己实心
     *
     * @param value
     */
    public abstract void setValue(Object value);
}
