31 lines
552 B
Go
31 lines
552 B
Go
// 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
|
|
}
|