17 lines
498 B
Go
17 lines
498 B
Go
package queue
|
|
|
|
import (
|
|
"openreplay/backend/pkg/kafka"
|
|
"openreplay/backend/pkg/license"
|
|
"openreplay/backend/pkg/queue/types"
|
|
)
|
|
|
|
func NewConsumer(group string, topics []string, handler types.MessageHandler, autoCommit bool, messageSizeLimit int) types.Consumer {
|
|
license.CheckLicense()
|
|
return kafka.NewConsumer(group, topics, handler, autoCommit, messageSizeLimit)
|
|
}
|
|
|
|
func NewProducer(messageSizeLimit int) types.Producer {
|
|
license.CheckLicense()
|
|
return kafka.NewProducer(messageSizeLimit)
|
|
}
|