// Package kafka ...
//
// Description : kafka ...
//
// Author : go_developer@163.com<白茶清欢>
//
// Date : 2025-12-31 21:54
package kafka

import "sync"

var (
	ConsumerManager = &consumerManager{
		l:             &sync.RWMutex{},
		instanceTable: map[string]IConsumeDataHandler{},
	}
)

type consumerManager struct {
	l             *sync.RWMutex
	instanceTable map[string]IConsumeDataHandler
}

func (cm *consumerManager) AddConsumer() error {
	return nil
}

func (cm *consumerManager) Instance(flag string) IConsumeDataHandler {
	return nil
}