Github user xvrl closed the pull request at:
https://github.com/apache/kafka/pull/4308
---
GitHub user xvrl opened a pull request:
https://github.com/apache/kafka/pull/4308
MINOR: make addWaiter public and fix exception handling
KafkaFuture.thenApply(...) only allows invoking a callback on normal
completion.
Making KafkaFuture.addWaiter(...) public makes possible
GitHub user xvrl opened a pull request:
https://github.com/apache/kafka/pull/4182
KAFKA-6163 fail fast on startup
skip loading remaining logs if we encounter an unrecoverable error on
startup
@hachikuji @ijuma
You can merge this pull request into a Git repository
GitHub user xvrl opened a pull request:
https://github.com/apache/kafka/pull/4123
MINOR: reset state in cleanup, fixes jmx mixin flakiness
@ewencp @ijuma
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/xvrl/kafka fix-jmx
GitHub user xvrl opened a pull request:
https://github.com/apache/kafka/pull/3818
MINOR: KAFKA-5742 follow-up, fix incorrect method name
@ewencp @ijuma
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/xvrl/kafka fix-startswith
Github user xvrl closed the pull request at:
https://github.com/apache/kafka/pull/3690
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature
GitHub user xvrl opened a pull request:
https://github.com/apache/kafka/pull/3690
Backport KAFKA-5742 support ZK chroot in system tests
backport of #3677
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/xvrl/kafka zk-chroot-0.11.0
Github user xvrl closed the pull request at:
https://github.com/apache/kafka/pull/2862
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature
GitHub user xvrl opened a pull request:
https://github.com/apache/kafka/pull/3677
KAFKA-5742 support ZK chroot in system tests
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/xvrl/kafka support-zk-chroot-in-tests
Alternatively
GitHub user xvrl opened a pull request:
https://github.com/apache/kafka/pull/3645
MINOR: support retrieving cluster_id in system tests
@ewencp
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/xvrl/kafka system-test-cluster-id
Github user xvrl closed the pull request at:
https://github.com/apache/kafka/pull/3090
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature
GitHub user xvrl opened a pull request:
https://github.com/apache/kafka/pull/3180
MINOR: reuse decompression buffers in log cleaner
follow-up to KAFKA-5150, reuse decompression buffers in the log cleaner
thread.
@ijuma @hachikuji
You can merge this pull request
GitHub user xvrl opened a pull request:
https://github.com/apache/kafka/pull/3090
KAFKA-5150 reduce lz4 decompression overhead - Backport to 0.10.2.x
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/xvrl/kafka kafka-5150-0.10
GitHub user xvrl opened a pull request:
https://github.com/apache/kafka/pull/3027
[WIP] KIP-155 KAFKA-5192 WindowStore range scan
Note: this implementation based on the initial version of the kip, and does
not reflect the latest changes that have yet to be agreed on.
@dguy
GitHub user xvrl opened a pull request:
https://github.com/apache/kafka/pull/3016
KAFKA-5216 fix error on peekNextKey in cached window/session store iterators
@guozhangwang @mjsax @dguy
You can merge this pull request into a Git repository by running:
$ git pull https
GitHub user xvrl opened a pull request:
https://github.com/apache/kafka/pull/2967
KAFKA-5150 reduce lz4 decompression overhead
- reuse decompression buffers, keeping one per thread
- switch lz4 input stream to operate directly on ByteBuffers
- more tests with both
GitHub user xvrl opened a pull request:
https://github.com/apache/kafka/pull/2863
KAFKA-5077 fix GC logging arguments for Java 9
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/xvrl/kafka fix-jdk9-gc-logs
Alternatively you can
GitHub user xvrl opened a pull request:
https://github.com/apache/kafka/pull/2862
KAFKA-5076: remove usage of java.xml.bind.* classes
* replaces base64 from DatatypeConverter with Base64 introduced in JDK 8
Given that we plan to stop supporting Java 7 in 0.11 this should
Github user xvrl closed the pull request at:
https://github.com/apache/kafka/pull/2063
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature
GitHub user xvrl opened a pull request:
https://github.com/apache/kafka/pull/2412
MINOR: reduce verbosity of cache flushes
This log message tends to be extremely verbose when state stores are being
restored
You can merge this pull request into a Git repository by running
GitHub user xvrl opened a pull request:
https://github.com/apache/kafka/pull/2402
KAFKA-4672 fix source compatibility for lambda expressions
please cherry-pick into 0.10.2.x
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/xvrl
GitHub user xvrl opened a pull request:
https://github.com/apache/kafka/pull/2363
MINOR: make methods introduced in KAFKA-4490 consistent with KIP-100
and remove some unnecessary @SuppressWarnings annotations
You can merge this pull request into a Git repository by running
Github user xvrl closed the pull request at:
https://github.com/apache/kafka/pull/2221
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature
GitHub user xvrl reopened a pull request:
https://github.com/apache/kafka/pull/2221
MINOR: fix metric collection NPE during shutdown
collecting socket server metrics during shutdown may throw
NullPointerException
You can merge this pull request into a Git repository by running
GitHub user xvrl opened a pull request:
https://github.com/apache/kafka/pull/2221
MINOR: fix metric collection NPE during shutdown
collecting socket server metrics during shutdown may throw
NullPointerException
You can merge this pull request into a Git repository by running
GitHub user xvrl opened a pull request:
https://github.com/apache/kafka/pull/2205
KAFKA-4481: relax streams api type contraints
Make appropriate methods contravariant in key and value types.
You can merge this pull request into a Git repository by running:
$ git pull https
GitHub user xvrl opened a pull request:
https://github.com/apache/kafka/pull/2186
KAFKA-4458 add per partition in-sync and assigned replica count
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/xvrl/kafka per-partition-replica
GitHub user xvrl opened a pull request:
https://github.com/apache/kafka/pull/2112
MINOR: fix typos and incorrect docs
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/xvrl/kafka minor-doc-fixes
Alternatively you can review
GitHub user xvrl opened a pull request:
https://github.com/apache/kafka/pull/2063
KAFKA-4346: Add foreachValue method to KStream
enables syntactic sugar using method references
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/xvrl
GitHub user xvrl opened a pull request:
https://github.com/apache/kafka/pull/2052
MINOR: add list_topics command to help debug tests
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/xvrl/kafka test-add-list-topics
Alternatively
GitHub user xvrl opened a pull request:
https://github.com/apache/kafka/pull/1962
KAFKA-4251: fix test driver not launching in Vagrant 1.8.6
custom ip resolver in test driver makes incorrect assumption when calling
vm.communicate.execute, causing driver to fail launching
31 matches
Mail list logo
