Commit Graph

15 Commits

Author SHA1 Message Date
de095367da cleanup
Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>
2021-03-24 23:22:00 +03:00
0795ba37c3 fix broker implementation
Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>
2021-02-10 00:19:08 +03: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
Asim Aslam
2f16be0629 replace config/cmd with cmd 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
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
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