Michal Harish
Michal Harish
It's mostly there, just needs a lock mechanism and a system test which should: 1. produce a batch of messages 2. run the job succesfully 3. produce another batch of...
Use parquet output format as a guiding example,and when stable create branches for kafka v0.9 and v 0.10
https://github.com/yulrizka/kafka-php/tree/v0.8
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...
doesn't play with JDK 9+
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...