Categorygithub.com/soedev/soego-component/ekafkaconsumerserver
package
1.0.1
Repository: https://github.com/soedev/soego-component.git
Documentation: pkg.go.dev
Overview
Versions
1
Dependencies
12
Dependents
2
Files
420 SLOC

# Functions

DefaultConfig returns a default config.
DefaultContainer 返回默认Container.
Load 载入配置，初始化Container.
NewConsumerServerComponent creates a new server instance.
WithDebug enables debug mode.
WithEkafka ...

# Constants

PackageName is the name of this component.

# Variables

No description provided by the author

# Structs

Component starts an Ego server for message consuming.
No description provided by the author

# Type aliases

OnConsumerGroupStartHandler ...
OnEachMessageHandler ...
OnStartHandler ...
No description provided by the author