canal

README

基于 debezium 和 kafka 的 binlog 订阅

暂时用于处理用户密码修改。

需要 dev-env 的 mq/ 文件夹中的组件

Documentation

Index

• func Main() error
• func OnSubjectChange(key json.RawMessage, payload payload)
• type SubjectPayload
• type UserKey

Functions

func Main

func Main() error

func OnSubjectChange

func OnSubjectChange(key json.RawMessage, payload payload)

Types

type SubjectPayload

type SubjectPayload struct {
	ID model.SubjectID `json:"subject_id"`
}

type UserKey

type UserKey struct {
	ID model.UserID `json:"uid"`
}