Versions in this module Expand all Collapse all v1 v1.1.0 Mar 21, 2022 v1.0.0 Feb 10, 2022 Changes in this version + func Kfk2Db(ctx context.Context, sc KfkStreamConsumer, db *sql.DB, num int, h HandleFunc, ...) error + type AsyncProducer interface + AsyncProduce func(context.Context, string) error + Close func() error + func MustNewAsyncProducer(topic string, brokerAddr []string) AsyncProducer + type HandleFunc func([]byte) (interface{}, error) + type KfkStreamConsumer interface + Close func() error + Commit func() error + Subscribe func(ctx context.Context, handle HandleFunc) chan interface{} + func MustNewKfkStreamConsumer(topic, group string, workerNum int, brokers []string) KfkStreamConsumer + type Producer interface + Close func() error + Produce func(string, string) error
Go to main page