|
6e5e2e0338
|
fix metrics
Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>
|
2023-04-29 21:32:19 +03:00 |
|
|
755bd187ba
|
move to micro v4
Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>
|
2023-04-28 22:49:29 +03:00 |
|
|
221b248b1f
|
Merge branch 'v3' into improve
|
2023-03-14 09:30:23 +03:00 |
|
|
a9b13378f3
|
improve performance and correctness
* properly handle rebalances
* simplify code
* return on NewBroker instance and not interface
Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>
|
2023-03-13 21:56:44 +03:00 |
|
|
6360f5e78f
|
propogate context to kgo record
Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>
|
2022-10-11 11:55:12 +03:00 |
|
|
203266aaea
|
fix noop codec usage and body only
Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>
|
2022-08-28 16:06:52 +03:00 |
|
|
d30f3d200b
|
fix panic on publish with not connected broker
Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>
|
2021-11-13 18:58:21 +03:00 |
|
|
2c74b3232b
|
support key publish option
Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>
|
2021-10-17 18:29:05 +03:00 |
|
|
69fb765b09
|
import guard
Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>
|
2021-10-03 18:32:41 +03:00 |
|
|
abfa9da1a9
|
use own domain
Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>
|
2021-10-03 18:30:56 +03:00 |
|
|
4b676bea64
|
skip marshal/unmarshal on noop codec
Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>
|
2021-09-23 07:06:51 +03:00 |
|
|
cc5d0ba4af
|
add connect checking
Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>
|
2021-09-17 07:56:31 +03:00 |
|
|
c89df95fdc
|
fixup
Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>
|
2021-09-15 18:30:07 +03:00 |
|
|
07fd48cd38
|
update to latest kgo
Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>
|
2021-09-02 00:20:55 +03:00 |
|
|
8dfa4f2a6d
|
add metrics
Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>
|
2021-08-30 20:02:32 +03:00 |
|
|
54ecafc4b1
|
cpu and memory optimizations
Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>
|
2021-08-27 02:24:43 +03:00 |
|
|
fe6d7d340e
|
perf fixes
Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>
|
2021-08-26 00:36:32 +03:00 |
|
|
e3b2a0d62b
|
many fixes
Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>
|
2021-08-25 21:51:15 +03:00 |
|
|
70a55ced3f
|
add backoff for reconnect
Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>
|
2021-08-24 13:20:31 +03:00 |
|
|
3f7fcaf4aa
|
intermediate fixes
Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>
|
2021-08-22 12:10:58 +03:00 |
|
|
fc9af8c63e
|
fix build, add comments
Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>
|
2021-08-09 16:49:04 +03:00 |
|
|
aad8a578fc
|
initial import
Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>
|
2021-08-09 00:30:36 +03:00 |
|
|
d750157d53
|
initial import
Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>
|
2021-07-10 23:41:21 +03:00 |
|