package com.tianbo.messagebus.kafka;


import lombok.extern.slf4j.Slf4j;
import org.apache.kafka.clients.consumer.KafkaConsumer;

import java.util.HashMap;
import java.util.Map;

/**
 * 消费者缓存类
 */
@Slf4j
public class ConsumersCache {
    public static Map<String, KafkaConsumer<String, String>> consumerMap;

    public static Map<String, KafkaConsumer<String, String>> getConsumerMap() {
        if (consumerMap !=null){
            return consumerMap;
        }
        log.trace("初始化消费者缓存");
        consumerMap = new HashMap<String, KafkaConsumer<String, String>>();
        return consumerMap;
    }
}