Szymon Matejczyk

Filtering of messages in transactional source buffer on revoke (#1062)

4

References #1062

Default PartitionAssignmentHandler behaviour on revoke+assing in transactional

5

### Short description `SingleSourceLogic` clears the buffer of accumulated records of revoked partitions only after new partitions are assigned. I think that this causes blocking `onRevoke` callback to wait for...

Emit messages from TransactionalFlow only after committing them

3

## Purpose Resolves #791 ## Changes Introduces waiting for commit message before emitting from an element from the `TransactionalProducerStage`. This has the following effect on the logic: After the `TransactionalProducerStage`...

Transactional.flow should emit only after a message is committed

4

### Short description Currently `Transactional.flow` emits elements downstream only after they are acked by a Kafka broker, but not necessarily after they are committed. This is counter intuitive, because it...

Configure timeout for "modifier when held, normal key otherwise"

5

**Is your feature request related to a problem? Please describe.** Configure timeout for "modifier when held, normal key otherwise". **Describe the solution you'd like** The default latency is much too...

Improve reading Int graphs

9

Now, both graph readers use Regex matching to read graphs. This is very inefficient for the Int case. Could be performed better avoiding regex for something like readInt from InputStream.

Improve SharedArrayBasedDirectedGraph documentation

2

i.a. some examples would be useful.

Currently for Traversals you have to specify the direction of edges that will be used. This is to allow walks on directed graphs as if they were undirected.

**Branch, version, commit** `develop` **Actual (wrong) behavior** There is a lot of evictions in dependency resolution also the following warning, when starting the application: ``` [2020-08-27 19:25:56,107] WARN akka.util.ManifestInfo [ManifestInfo(akka://akka-test)]...

E2E benchmarking of FiloDB

1

I was wondering: do you have any E2E benchmarks of FiloDB? I'm not interested in the pure results, but more of how you're thinking of performance requirements for Filo. If...