kafkaHander

package

v2.3.1 Latest Latest Go to latest Published: Jan 29, 2026 License: MIT Imports: 12 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type Instance struct {
	// contains filtered or unexported fields
}

func New(opts *pubsub.Options, k ...any) (*Instance, error)

New 创建kafkaHander实例

func (this *Instance) Publish(param pubsub.Params, msg any) error

Publish 发布消息

func (this *Instance) Subscribe(param pubsub.Params, cbs *pubsub.Cbfunc)

Subscribe 订阅消息关于kafka订阅，如果topic一样，需要进行合并，通过key来判断是否是同一个消息如果topic不一样，就分开消费