package com.elab.core.kafka.consumer;

import org.springframework.kafka.listener.BatchAcknowledgingMessageListener;

/**
 * @Module TODO
 * @Description TODO
 * @Author liukaixiong
 * @Date 2020/12/28 15:16
 */
public abstract class AbstractBatchKafkaConsumer implements BatchAcknowledgingMessageListener<String, String> {

    /**
     * 订阅的topic消息
     *
     * @return
     */
    public abstract String subscribeTopic();
}
