Commit Graph

11 Commits

Author SHA1 Message Date
c8139b4b8c fix go.mod
Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>
2021-01-19 15:39:53 +03:00
8232a91f11 update go-micro and fix client/selector usage
Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>
2021-01-19 15:39:53 +03:00
921e347872 add proper replace in broker
Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>
2021-01-19 15:39:53 +03:00
b4c8df7a27 bump go-micro to current master
Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>
2021-01-19 15:39:53 +03:00
da3f8bf17e update go-micro and micro to v2.9.1
Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>
2021-01-19 15:39:53 +03:00
842e1095f7 broker/segmentio: fix writer deadlock
Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>
2021-01-19 15:39:53 +03:00
d9c3a34d39 pin to micro and go-micro 2.8.0 release
Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>
2021-01-19 15:39:53 +03:00
202e3d8c4e update go-micro to v2.5.0
Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>
2021-01-19 15:39:53 +03:00
a03e2e267a segmentio improvements for broker and codec (#531)
* segmentio broker and codec improvements
* broker/segmentio: return error on subscribe

Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>
2021-01-19 15:39:53 +03:00
cba22d5cf0 broker/segmentio: parallel partition processing
Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>
2021-01-19 15:39:53 +03:00
0a547f3b11 add segmentio kafka broker (#518)
* add segmentio kafka broker

Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>
2021-01-19 15:39:53 +03:00