Categorygithub.com/kevinyjn/gocommqkafka
package
0.3.1
Repository: https://github.com/kevinyjn/gocom.git
Documentation: pkg.go.dev
Overview
Versions
1
Dependencies
16
Dependents
1
Files
1k SLOC

# Functions

ConvertKafkaPacketToMQConsumerMessage 把接收到的kafkaPacket 数据转换成MQConsumerMessage.
GetKafka 获取kafka.
InitKafka 初始化kafka.
NewConsumer 实例化返回消费者.
NewKafkaWorker 实例化一个kafka worker.
NewProducer 返回一个生产者.
停止kafka.

# Variables

No description provided by the author

# Structs

Base .
Config kafkav2 配置参数.
Consumer 消费者.
InstStats .
No description provided by the author
No description provided by the author
KafkaWorker 把生产者、消费者结合起来，实现请求响应模式.
Producer 生产者.
Stats struct.

# Type aliases

CallBack .回调函数.
Worker 订阅topic 后处理收到信息的回调函数.