Commit Graph

74 Commits

Author SHA1 Message Date
Renovate Bot
6ac0918be1
Add renovate.json 2021-02-08 23:08:30 +00:00
51f77581bc move trace log to condition
Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>
2021-01-20 22:16:59 +03:00
ef49b96583 use own fork
Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>
2021-01-19 15:53:47 +03:00
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
Asim Aslam
2f16be0629 replace config/cmd with cmd 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
9b9387d916 broker/segmentio: speedup publish
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
033d130253 broker/segmentio: fixup kafka reconnection logic
Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>
2021-01-19 15:39:53 +03:00
62d02b4297 broker/segmentio: fix kafka topic in publication
Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>
2021-01-19 15:39:53 +03:00
dd94415716 broker/segmentio: fix offsets
Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>
2021-01-19 15:39:53 +03:00
5cad4c7723 broker/segmentio: fix offset handle
Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>
2021-01-19 15:39:53 +03:00
03a583d9d4 broker/segmentio: intermediate rewrite
Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>
2021-01-19 15:39:53 +03:00
6a3018a9bc broker/segmentio: tmp revert
Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>
2021-01-19 15:39:53 +03:00
be82d76d81 broker/segmentio: fix error
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
hello2t
9353991c21 fix readerConfig.Brokers and writerConfig.Brokers 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