GitHub user dajac opened a pull request:
https://github.com/apache/kafka/pull/786
MINOR: MemoryRecords.sizeInBytes throws NPE when non-writable.
I just noticed that `MemoryRecords.sizeInBytes` throws NPE when
MemoryRecords is non-writable. `compressor` is explicitly set to null
GitHub user dajac opened a pull request:
https://github.com/apache/kafka/pull/774
KAFKA-3098: "partition.assignment.strategy" appears twice in documentation
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/dajac/kafka
GitHub user dajac opened a pull request:
https://github.com/apache/kafka/pull/752
KAFKA-3085: BrokerChangeListener computes inconsistent live/dead broker list
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/dajac/kafka KAFKA
GitHub user dajac opened a pull request:
https://github.com/apache/kafka/pull/756
KAFKA-3085: BrokerChangeListener computes inconsistent live/dead broker
list.
Follow up PR as per comments in the ticket.
@junrao It should be correct now as `curBrokers` included only live
GitHub user dajac opened a pull request:
https://github.com/apache/kafka/pull/714
MINOR: Tiny optimization to avoid mapping twice on the results.
As pointed out by @granthenke in #196, error can be wrapped in JShort
directly to avoid second map.
You can merge this pull request
GitHub user dajac opened a pull request:
https://github.com/apache/kafka/pull/196
KAFKA-2072: Replace StopReplica Request/Response with their
org.apache.kafka.common.requests equivalents
You can merge this pull request into a Git repository by running:
$ git pull https
GitHub user dajac opened a pull request:
https://github.com/apache/kafka/pull/170
KAFKA-2072: Add StopReplica request/response to o.a.k.common.requests
This PR adds StopReplica request and response as it is required by @ijuma
for KAFKA-2411. Migration of core module is addressed
Github user dajac closed the pull request at:
https://github.com/apache/kafka/pull/141
---
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 dajac opened a pull request:
https://github.com/apache/kafka/pull/141
KAFKA-2072 [WIP]: Add StopReplica request/response to o.a.k.common.requests
and replace the usage in core module
Migration is done but this PR will need to be rebased on #110. I have
copied some
GitHub user dajac opened a pull request:
https://github.com/apache/kafka/pull/110
KAFKA-2071: Replace Producer Request/Response with their
org.apache.kafka.common.requests equivalents
This PR replaces all producer request/response with their common
equivalents but doesn't touch
10 matches
Mail list logo
