使用命令行传入配置参数：
- -csmr (uint)：消费者组的消费者个数
- -topic (string)：Kafka中的Topic
- -ipaddr (string)：Kafka服务的IPv4地址
- -port (string)：Kafka服务的端口
执行 ./bin目录下的 csmr 文件
-
Notifications
You must be signed in to change notification settings - Fork 0
根据alibaba/canal源码中Consumer的源码，自己实现了Golang版本的KafkaConsumer，用于接受并解析Canal组件发送给Kafka的消息。
License
PatchouliTIS/CanalKafka-GoConsumer
Folders and files
| Name | Name | Last commit message | Last commit date | |
|---|---|---|---|---|
Repository files navigation
About
根据alibaba/canal源码中Consumer的源码，自己实现了Golang版本的KafkaConsumer，用于接受并解析Canal组件发送给Kafka的消息。
Resources
License
Stars
Watchers
Forks
Releases
No releases published
Packages 0
No packages published