affinity
affinity copied to clipboard
amient
Library and a Framework for building fast, scalable, fault-tolerant Data APIs based on Akka, Avro, ZooKeeper and Kafka
Currently if the gateway goes into suspended state it has potential to hang indefinitely. This should be limited by a new timeout configuration after which the node should fail.
1. don't require streams to have num partitions in which case they will not be auto-created 2. kv stores can also be configured without num.partitions in which case they will...
The purpose of the coordinator is to allow nodes to come online and offline dynamically. This is achieved by the following 3 functions: 1. inform about nodes coming online/offline and...
https://github.com/facebook/rocksdb/wiki/Compaction-Filter The timestamp is wrapped in the value bytes as 8 bytes big endian first and the ttl could be passed through rocksdb options. - RocksDB C++ Compaction Filters for...
This is useful for config auto-configuring streams when they are first time created but it has to be storage specific.
ActorPublisher was deprecated in akka 2.5+ but the new implementation with GraphStage seems to be a bit slow - could be incorrect stream buffering
if remote config is forgotten the cluster goes into a partitioned state from which it can only recover by removing the ZIDs from the local storage - this can be...