Eric Lindvall
Eric Lindvall
I've been adding some fixes in a fork over at https://github.com/papertrail/kestrel. I would be interested in working with me, I would welcome it. Would creating a kestrel repo in a...
I have a working branch over at https://github.com/papertrail/kestrel that has fixed these sbt problems.
:+1: Thanks for tracking this down! I've observed the behavior before but haven't had a chance to dig into why.
You can use `Option.apply(the_thing)` to instantiate an Option.
Also, if you want to fix the problem of seeing `%s` in the logs, this can help: https://gist.github.com/eric/13f12b1f044fe8fd9b3a
For the `expireToQueue` setting, you may want to use `Option.empty()` instead of `Option.apply("None")` to represent nothing.
Cool. I've recently been bitten by how RabbitMQ handles a queue getting very far behind so I'm very concerned with performance in this degraded case. I really appreciate the way...
Have you experimented with using a `BufferedInputStream` for reading the journals to reduce the number of reads syscalls that are happening in `readJournalEntry()`? For sequential reading like this it seems...
I just realized that `BufferedInputStream` does not have a `getChannel()` method, so it wouldn't be possible to use it with the channel operations...
It appears this is the solution to unmmap()-ing: https://github.com/apache/cassandra/blob/f69e043ce4a4c8ecba6682fcd7ddf771a773afea/src/java/org/apache/cassandra/io/util/FileUtils.java#L52-L68 https://github.com/apache/cassandra/blob/f69e043ce4a4c8ecba6682fcd7ddf771a773afea/src/java/org/apache/cassandra/io/util/FileUtils.java#L272-L291