TANK
TANK copied to clipboard
A very high performance distributed log service
For consume responses, where the returned response size is too high, instead of ingesting the whole response into the buffer, we can instead parse bundles as they arrive using a...
- [ ] Allow compactions even if no duplicate keys are found Now, if no duplicate keys are identified after all messages are collected from all involved RO Logs, no...
Now, when not running in cluster-aware mode, the directory name for the topic will be prepended with '.', and only when all partitions for that topic have been initialized (in...
C++2a coroutines are extremely powerful. As far as I am concerned, its the most important high-impact feature to be introduced in the langue together with lambdas and move semantics. We...
When you use the `produce` APIs to publish events/messages, a new batch is created immediately and transmitted to the respective TANK endpoint(s). The Kafka Producer supports batching (controlled via "batch.size"...
Hi, We're looking to integrate TANK into a (mostly C++) project that we build using the CMake build system, so it would help if TANK could also be built with...
@kostas on @dist-sys(Slack) came up with a great idea. Instead of retaining the _last_ message in a set of messages with the same key, retain the _first_ instead (during compactions)....
track_inflight_req(), consider_inflight_reqs() and forget_inflight_req() implementation is pending. We need to implement them so that we can deal with requests where the response takes too long, e.g if you just stop...
Can I run it on Windows platform or just only support Linux? There was no specific platform details in README.
We currently don't compress the consume responses (i.e message sets streamed from the server to the client), because we rely on sendfile() -- but maybe, depending on the size of...