package com.elab.core.kafka.consumer;

import org.springframework.kafka.listener.AcknowledgingMessageListener;

/**
 * @Module TODO
 * @Description TODO
 * @Author liukaixiong
 * @Date 2020/10/27 16:05
 */
public abstract class AbstractKafkaConsumer implements AcknowledgingMessageListener<String, String> {
    /**
     * 订阅的topic消息
     *
     * @return
     */
    public abstract String subscribeTopic();

}
