[GitHub] kafka pull request #2159: KAFKA 4273 - Add TTL support for RocksDB

2016-11-22 Thread dpoldrugo
GitHub user dpoldrugo opened a pull request: https://github.com/apache/kafka/pull/2159 KAFKA 4273 - Add TTL support for RocksDB Since Streams DSL doesn't support fine grained configurations of state stores (it usese only RocksDB) - I have added new StreamsConfig c

[GitHub] kafka pull request #2188: KAFKA-4455; ensure tasks are closed after CommitFa...

2016-11-29 Thread dpoldrugo
GitHub user dpoldrugo opened a pull request: https://github.com/apache/kafka/pull/2188 KAFKA-4455; ensure tasks are closed after CommitFailedException Details can be found in the task: [KAFKA-4455](https://issues.apache.org/jira/browse/KAFKA-4455) Some discussion was also

[GitHub] kafka pull request #2949: KAFKA-5055: Kafka Streams skipped-records-rate sen...

2017-04-30 Thread dpoldrugo
GitHub user dpoldrugo opened a pull request: https://github.com/apache/kafka/pull/2949 KAFKA-5055: Kafka Streams skipped-records-rate sensor bug Fix as described in the [KAFKA-5055 Jira comment](https://issues.apache.org/jira/browse/KAFKA-5055?focusedCommentId=15990086&