No description or website provided.
Go
Fetching latest commit…
Cannot retrieve the latest commit at this time.
Permalink
Failed to load latest commit information.
Godeps
binlog_ops.go
config.go
config.toml
consumer.go
es_ops.go
log.go
main.go
readme.md
util.go

readme.md

从kafka中消费canal server产生的binlog,然后同步到es的river工具。

NOTICE 现在只能解析固定格式的binlog,不够通用,所以只作参考