Resync 0.10.1 documentation
Project: http://git-wip-us.apache.org/repos/asf/kafka-site/repo
Commit: http://git-wip-us.apache.org/repos/asf/kafka-site/commit/b2433ce9
Tree: http://git-wip-us.apache.org/repos/asf/kafka-site/tree/b2433ce9
Diff:
Repository: kafka-site
Updated Branches:
refs/heads/asf-site 234f865d3 -> 20f28764b
update htaccess to load images nested inside of doc folders
stop forcing code elements to be blocks
Project: http://git-wip-us.apache.org/repos/asf/kafka-site/repo
Commit:
Repository: kafka
Updated Branches:
refs/heads/trunk 8e9e63138 -> 2e82bc0a1
MINOR: Add images missing from documentation
Author: Jason Gustafson
Reviewers: Ewen Cheslack-Postava
Closes #2008 from hachikuji/add-missing-images
Project:
Repository: kafka
Updated Branches:
refs/heads/0.10.1 d1f691a56 -> d981dd25b
MINOR: Add images missing from documentation
Author: Jason Gustafson
Reviewers: Ewen Cheslack-Postava
Closes #2008 from hachikuji/add-missing-images
(cherry picked from
Repository: kafka
Updated Branches:
refs/heads/trunk 53fc26723 -> 34e9cc5df
KAFKA-4349; Handle 'PreparingRebalance' and 'AwaitingSync' states in consumer
group describe
The edge case where consumer group state is `PreparingRebalance` or
`AwaitingSync` will be separately handled as the group
Repository: kafka
Updated Branches:
refs/heads/trunk 5307efe1a -> 8f2e0a5ec
MINOR: Fix regex on connector path param in ConnectorsResource
Author: Ewen Cheslack-Postava
Reviewers: Shikhar Bhushan , Konstantine Karantasis
,
Repository: kafka
Updated Branches:
refs/heads/trunk b8cfa167e -> 2965f50e0
MINOR: Replaced unnecessary map and getOrElse with exists
Author: himani1 <1himani.ar...@gmail.com>
Reviewers: Jason Gustafson
Closes #2035 from himani1/code_refactored
Project:
Repository: kafka-site
Updated Branches:
refs/heads/asf-site 230d32e67 -> 9bad5a3b7
Resync 0.10.1 for 0.10.1.0 release
Project: http://git-wip-us.apache.org/repos/asf/kafka-site/repo
Commit: http://git-wip-us.apache.org/repos/asf/kafka-site/commit/9bad5a3b
Tree:
Repository: kafka
Updated Branches:
refs/heads/trunk 179d06985 -> fb22685fa
MINOR: Fixed incomplete sentence in introduction docs
Author: Jakub Dziworski
Reviewers: Guozhang Wang , Jason Gustafson
Closes #1994 from
Repository: kafka
Updated Branches:
refs/heads/trunk e7663a306 -> 6199c6277
KAFKA-4303; Ensure commitSync does not block unnecessarily in poll without
in-flight requests
Author: Jason Gustafson
Reviewers: Guozhang Wang , Ismael Juma
Repository: kafka
Updated Branches:
refs/heads/0.10.1 dbe676720 -> f287efaff
KAFKA-4303; Ensure commitSync does not block unnecessarily in poll without
in-flight requests
Author: Jason Gustafson
Reviewers: Guozhang Wang , Ismael Juma
Repository: kafka
Updated Tags: refs/tags/0.10.1.0-rc3 [created] 50f30a44f
Resync 0.10.1 docs for RC3
Project: http://git-wip-us.apache.org/repos/asf/kafka-site/repo
Commit: http://git-wip-us.apache.org/repos/asf/kafka-site/commit/230d32e6
Tree: http://git-wip-us.apache.org/repos/asf/kafka-site/tree/230d32e6
Diff:
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/230d32e6/0101/javadoc/org/apache/kafka/common/serialization/Serdes.ByteArraySerde.html
--
diff --git
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/230d32e6/0101/javadoc/org/apache/kafka/common/config/ConfigDef.Type.html
--
diff --git a/0101/javadoc/org/apache/kafka/common/config/ConfigDef.Type.html
Repository: kafka-site
Updated Branches:
refs/heads/asf-site a6986e073 -> 230d32e67
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/230d32e6/0101/javadoc/org/apache/kafka/streams/kstream/JoinWindows.html
--
diff --git
Repository: kafka
Updated Branches:
refs/heads/trunk 6199c6277 -> 4e0b0b83a
MINOR: Code refactor - cleaning up some boolean assignments
Author: Ishita Mandhan
Reviewers: Vahid Hashemian , Jason Gustafson
Closes #2013 from
Repository: kafka
Updated Branches:
refs/heads/trunk 925310aac -> 6f842c1e9
KAFKA-4310; Add missing Windows script `kafka-consumer-groups.bat`
add file 'kafka-consumer-groups.bat' for Windows platform
Author: amethystic
Reviewers: Vahid Hashemian
Update download page for 0.10.1.0
Project: http://git-wip-us.apache.org/repos/asf/kafka-site/repo
Commit: http://git-wip-us.apache.org/repos/asf/kafka-site/commit/12ad81e4
Tree: http://git-wip-us.apache.org/repos/asf/kafka-site/tree/12ad81e4
Diff:
Repository: kafka-site
Updated Branches:
refs/heads/asf-site 9bad5a3b7 -> 12ad81e44
Enable 0.10.1 documentation
Project: http://git-wip-us.apache.org/repos/asf/kafka-site/repo
Commit: http://git-wip-us.apache.org/repos/asf/kafka-site/commit/ac2567c7
Tree:
Repository: kafka
Updated Branches:
refs/heads/trunk 2ac70c0b7 -> 302a246c7
KAFKA-4296; Fix LogCleaner statistics rolling
Author: Jason Gustafson
Reviewers: Ismael Juma
Closes #2016 from hachikuji/KAFKA-4296
Project:
Repository: kafka
Updated Branches:
refs/heads/trunk 62c0972ef -> 5cf579a7e
MINOR: Fix vagrant rsync exclude argument
Existing VMs will need to be re-provisioned or re-created to pick up this
change.
Reference docs:
https://www.vagrantup.com/docs/synced-folders/rsync.html
Author: Magnus
Repository: kafka
Updated Branches:
refs/heads/trunk 2965f50e0 -> 332b8b9af
KAFKA-4319; Parallelize shutdown of fetchers in AbstractFetcherManager to
speedup shutdown
Author: Alexey Ozeritsky
Reviewers: Ismael Juma , Jason Gustafson
Author: jgus
Date: Wed Oct 19 18:39:44 2016
New Revision: 16588
Log:
Add 0.10.1.0 artifacs so that PMC can promote them
[This commit notification would consist of 75 parts,
which exceeds the limit of 50 ones, so it was shortened to the summary.]
Repository: kafka
Updated Tags: refs/tags/0.10.1.0 [created] 88d865799
Repository: kafka
Updated Branches:
refs/heads/0.10.1 b729ac520 -> fb3f1f978
Bump version to 0.10.1.1-SNAPSHOT
Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/fb3f1f97
Tree:
Bump version to 0.10.1.0
Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/5bdcbebd
Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/5bdcbebd
Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/5bdcbebd
Branch:
Repository: kafka
Updated Branches:
refs/heads/0.10.1 9f8dc1301 -> d273480c4
MINOR: Remove duplicate doc headers
Author: Manikumar Reddy O
Reviewers: Jason Gustafson
Closes #2021 from omkreddy/LATEST-DOC-CHANGE
(cherry picked from commit
Repository: kafka
Updated Branches:
refs/heads/trunk 6f842c1e9 -> 3c02e5a20
MINOR: Remove duplicate doc headers
Author: Manikumar Reddy O
Reviewers: Jason Gustafson
Closes #2021 from omkreddy/LATEST-DOC-CHANGE
Project:
Repository: kafka
Updated Branches:
refs/heads/trunk 1f1d45006 -> 3b4c34794
http://git-wip-us.apache.org/repos/asf/kafka/blob/3b4c3479/core/src/main/scala/kafka/server/KafkaApis.scala
--
diff --git
http://git-wip-us.apache.org/repos/asf/kafka/blob/3b4c3479/clients/src/main/java/org/apache/kafka/common/record/LogInputStream.java
--
diff --git
a/clients/src/main/java/org/apache/kafka/common/record/LogInputStream.java
http://git-wip-us.apache.org/repos/asf/kafka/blob/3b4c3479/clients/src/main/java/org/apache/kafka/common/requests/RequestSend.java
--
diff --git
a/clients/src/main/java/org/apache/kafka/common/requests/RequestSend.java
http://git-wip-us.apache.org/repos/asf/kafka/blob/3b4c3479/clients/src/test/java/org/apache/kafka/clients/producer/internals/SenderTest.java
--
diff --git
KAFKA-2066; Use client-side FetchRequest/FetchResponse on server
Author: Jason Gustafson
Reviewers: Jun Rao
Closes #2069 from hachikuji/KAFKA-2066
Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit:
Repository: kafka
Updated Branches:
refs/heads/trunk 64a860c58 -> 7282de39f
KAFKA-4081; KafkaConsumer should not allow negative offsets to be committed
Author: Mickael Maison
Reviewers: Jiangjie Qin , Jason Gustafson
Repository: kafka
Updated Branches:
refs/heads/trunk 31203efcb -> b902ef985
MINOR: Remove unused `ByteBoundedBlockingQueue` class and `zkSessionTimeout`
parameter
Author: Ismael Juma
Reviewers: Jason Gustafson
Closes #2136 from
Repository: kafka
Updated Branches:
refs/heads/trunk 76b070284 -> 979a7baa7
MINOR: Fix issue in `AsyncProducerTest` where it expects the `port` config to
be set
This test fails locally when I run it, but somehow Jenkins builds are passed.
Not clear how.
Author: Ismael Juma
Repository: kafka
Updated Branches:
refs/heads/trunk fbbe5821c -> 94909a8f8
KAFKA-4357; Fix consumer group describe output when there is no active member
(old consumer)
Author: Vahid Hashemian
Reviewers: Sriharsha Chintalapani , Jason
Repository: kafka
Updated Branches:
refs/heads/trunk dab3617e1 -> 53fc26723
MINOR: Increase zk connection timeout in tests for client created in
`KafkaServer`
We had already made this change to the client created in `ZooKeeperTestHarness`.
I last saw this failure when
Repository: kafka
Updated Branches:
refs/heads/trunk 1a2ed8633 -> e795ad96c
KAFKA-4024; Override client metadata backoff on topic changes and avoid
unnecessary connections
Fixes a bug that inappropriately applies backoff as interval between metadata
updates even though the current one is
Repository: kafka
Updated Branches:
refs/heads/trunk c62dc28ce -> 2959bc2ad
MINOR: Replaced unnecessary isDefined and get on option values with fold
Author: himani1 <1himani.ar...@gmail.com>
Reviewers: Jason Gustafson
Closes #2050 from himani1/refactored_code
Project:
Repository: kafka
Updated Branches:
refs/heads/0.10.1 a1afb7394 -> 77bf1dc7c
KAFKA-4130; Link to Varnish architect notes is broken
Author: Andrea Cosentino
Reviewers: Jason Gustafson
Closes #1835 from oscerd/KAFKA-4130
(cherry picked from commit
Repository: kafka
Updated Branches:
refs/heads/trunk c1e840050 -> 9179bbc06
KAFKA-4130; Link to Varnish architect notes is broken
Author: Andrea Cosentino
Reviewers: Jason Gustafson
Closes #1835 from oscerd/KAFKA-4130
Project:
Repository: kafka
Updated Branches:
refs/heads/trunk 93b940016 -> ae9532c6b
MINOR: Fixed broken links in the documentation
Author: Vahid Hashemian
Reviewers: Jason Gustafson
Closes #2010 from vahidhashemian/doc/fix_hyperlinks
Project:
Repository: kafka
Updated Branches:
refs/heads/0.10.1 5fe9b81c1 -> aaefe686b
MINOR: Fixed broken links in the documentation
Author: Vahid Hashemian
Reviewers: Jason Gustafson
Closes #2010 from vahidhashemian/doc/fix_hyperlinks
(cherry picked
Repository: kafka
Updated Branches:
refs/heads/trunk 65f6a7964 -> 1a67739c2
KAFKA-4254; Update producer's metadata before failing on non-existent partitions
Author: Konstantine Karantasis
Reviewers: Ismael Juma , Jason Gustafson
Repository: kafka
Updated Branches:
refs/heads/0.10.1 5ed8fc00d -> ed8c797af
KAFKA-4254; Update producer's metadata before failing on non-existent partitions
Author: Konstantine Karantasis
Reviewers: Ismael Juma , Jason Gustafson
Repository: kafka
Updated Branches:
refs/heads/0.10.1 ed8c797af -> fc1551d40
KAFKA-4298; Ensure compressed message sets are not converted when log cleaning
Author: Jason Gustafson
Reviewers: Ismael Juma , Jun Rao
Closes #2019 from
Repository: kafka
Updated Branches:
refs/heads/0.10.1 e7407529f -> 401fe0a9b
MINOR: Make documentation follow latest template
Make the latest version of our docs follow the latest site template structure.
Author: Derrick Or
Reviewers: Jason Gustafson
Repository: kafka
Updated Branches:
refs/heads/0.10.1 401fe0a9b -> 6956a3819
http://git-wip-us.apache.org/repos/asf/kafka/blob/6956a381/docs/implementation.html
--
diff --git a/docs/implementation.html
MINOR: Fix typos in documentation
And improve readability by adding proper punctuations.
Author: Vahid Hashemian
Reviewers: Jason Gustafson
Closes #2002 from vahidhashemian/doc/fix_typos
Project:
MINOR: Fix typos in documentation
And improve readability by adding proper punctuations.
Author: Vahid Hashemian
Reviewers: Jason Gustafson
Closes #2002 from vahidhashemian/doc/fix_typos
(cherry picked from commit
Repository: kafka
Updated Branches:
refs/heads/0.10.1 6956a3819 -> d1f691a56
MINOR: Fix table of contents and section numbers in the documentation
Removed a non-existing reference in table of contents and fixed some section
numbers.
Author: Vahid Hashemian
Repository: kafka
Updated Branches:
refs/heads/trunk e972d2afd -> 8e9e63138
MINOR: Fix table of contents and section numbers in the documentation
Removed a non-existing reference in table of contents and fixed some section
numbers.
Author: Vahid Hashemian
Repository: kafka
Updated Branches:
refs/heads/trunk 1bce0d1b5 -> 06d6d98be
MINOR: Make documentation follow latest template
Make the latest version of our docs follow the latest site template structure.
Author: Derrick Or
Reviewers: Jason Gustafson
Repository: kafka-site
Updated Branches:
refs/heads/asf-site 72f3f9add -> 234f865d3
Additional doc fixes for 0.10.1
Project: http://git-wip-us.apache.org/repos/asf/kafka-site/repo
Commit: http://git-wip-us.apache.org/repos/asf/kafka-site/commit/234f865d
Tree:
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/a6986e07/0101/javadoc/org/apache/kafka/common/config/ConfigDef.Validator.html
--
diff --git
a/0101/javadoc/org/apache/kafka/common/config/ConfigDef.Validator.html
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/a6986e07/0101/javadoc/org/apache/kafka/common/serialization/Serdes.ByteBufferSerde.html
--
diff --git
Resync 0.10.1 docs for RC2
Project: http://git-wip-us.apache.org/repos/asf/kafka-site/repo
Commit: http://git-wip-us.apache.org/repos/asf/kafka-site/commit/a6986e07
Tree: http://git-wip-us.apache.org/repos/asf/kafka-site/tree/a6986e07
Diff:
Repository: kafka
Updated Branches:
refs/heads/trunk 6626b058c -> 67f1e5b91
http://git-wip-us.apache.org/repos/asf/kafka/blob/67f1e5b9/core/src/test/scala/unit/kafka/server/FetchRequestTest.scala
--
diff --git
http://git-wip-us.apache.org/repos/asf/kafka/blob/67f1e5b9/core/src/test/scala/unit/kafka/log/LogTest.scala
--
diff --git a/core/src/test/scala/unit/kafka/log/LogTest.scala
b/core/src/test/scala/unit/kafka/log/LogTest.scala
index
http://git-wip-us.apache.org/repos/asf/kafka/blob/67f1e5b9/clients/src/main/java/org/apache/kafka/common/record/RecordsIterator.java
--
diff --git
a/clients/src/main/java/org/apache/kafka/common/record/RecordsIterator.java
http://git-wip-us.apache.org/repos/asf/kafka/blob/67f1e5b9/core/src/test/scala/unit/kafka/log/LogCleanerIntegrationTest.scala
--
diff --git a/core/src/test/scala/unit/kafka/log/LogCleanerIntegrationTest.scala
http://git-wip-us.apache.org/repos/asf/kafka/blob/67f1e5b9/core/src/main/scala/kafka/server/ReplicaManager.scala
--
diff --git a/core/src/main/scala/kafka/server/ReplicaManager.scala
KAFKA-4390; Replace MessageSet usage with client-side alternatives
Author: Jason Gustafson
Reviewers: Ismael Juma , Guozhang Wang ,
Jun Rao
Closes #2140 from hachikuji/KAFKA4390
Project:
http://git-wip-us.apache.org/repos/asf/kafka/blob/67f1e5b9/clients/src/main/java/org/apache/kafka/common/record/LogInputStream.java
--
diff --git
a/clients/src/main/java/org/apache/kafka/common/record/LogInputStream.java
http://git-wip-us.apache.org/repos/asf/kafka/blob/67f1e5b9/clients/src/test/java/org/apache/kafka/common/record/RecordTest.java
--
diff --git
a/clients/src/test/java/org/apache/kafka/common/record/RecordTest.java
http://git-wip-us.apache.org/repos/asf/kafka/blob/67f1e5b9/core/src/main/scala/kafka/log/LogSegment.scala
--
diff --git a/core/src/main/scala/kafka/log/LogSegment.scala
b/core/src/main/scala/kafka/log/LogSegment.scala
index
Repository: kafka
Updated Branches:
refs/heads/trunk e55205b81 -> b58b6a1be
http://git-wip-us.apache.org/repos/asf/kafka/blob/b58b6a1b/core/src/test/scala/unit/kafka/server/FetchRequestTest.scala
--
diff --git
Repository: kafka
Updated Branches:
refs/heads/trunk f0acc4a0d -> efeaf1298
KAFKA-4405; Avoid unnecessary network poll in consumer if no fetches sent
Author: Eno Thereska
Reviewers: Ismael Juma , Jason Gustafson
Closes #2193
Repository: kafka
Updated Branches:
refs/heads/trunk 01d58ad8e -> 36528df08
MINOR: Fix typos in KafkaConsumer docs
Author: Jeff Widman
Reviewers: Jason Gustafson
Closes #2178 from jeffwidman/patch-1
Project:
Repository: kafka
Updated Branches:
refs/heads/trunk 9684487b4 -> 055ca9b7a
KAFKA-4272; Add missing 'connect' Windows batch scripts
Author: Vahid Hashemian
Reviewers: Jason Gustafson
Closes #2146 from vahidhashemian/KAFKA-4272
Project:
Repository: kafka
Updated Branches:
refs/heads/trunk 36528df08 -> 9684487b4
KAFKA-4375; Reset interrupt state in a few places where InterruptedException is
caught
See https://issues.apache.org/jira/browse/KAFKA-4375
Author: Stig Rohde Døssing
Reviewers: Jason Gustafson
http://git-wip-us.apache.org/repos/asf/kafka/blob/d2567188/core/src/main/scala/kafka/server/KafkaConfig.scala
--
diff --git a/core/src/main/scala/kafka/server/KafkaConfig.scala
b/core/src/main/scala/kafka/server/KafkaConfig.scala
KAFKA-4565; Separation of Internal and External traffic (KIP-103)
Author: Ismael Juma
Reviewers: Gwen Shapira , Jason Gustafson
Closes #2354 from ijuma/kafka-4565-separation-of-internal-and-external-traffic
Project:
Repository: kafka
Updated Branches:
refs/heads/trunk 80d6c64c1 -> d25671884
http://git-wip-us.apache.org/repos/asf/kafka/blob/d2567188/core/src/test/scala/unit/kafka/server/AdvertiseBrokerTest.scala
--
diff --git
Repository: kafka
Updated Branches:
refs/heads/trunk 6496271a1 -> f6fee34a2
KAFKA-4627; Fix timing issue in consumer close tests
Author: Rajini Sivaram
Reviewers: Apurva Mehta , Jason Gustafson
Closes #2367 from
Repository: kafka
Updated Branches:
refs/heads/trunk 88fdca26a -> c2d9b95f3
http://git-wip-us.apache.org/repos/asf/kafka/blob/c2d9b95f/core/src/test/scala/unit/kafka/coordinator/GroupMetadataManagerTest.scala
--
diff --git
Repository: kafka
Updated Branches:
refs/heads/trunk ecff8544d -> f72203ee9
KAFKA-4426; Add close with timeout for KafkaConsumer (KIP-102)
Author: Rajini Sivaram
Reviewers: Ismael Juma , Apurva Mehta
, Jason Gustafson
Repository: kafka
Updated Branches:
refs/heads/0.10.1 b1f8fc7b6 -> aec74ae5b
KAFKA-4469; Fix consumer performance regression from inefficient list removal
and copy
Author: Jason Gustafson
Reviewers: Ismael Juma , Guozhang Wang
Repository: kafka
Updated Branches:
refs/heads/trunk 8d188c911 -> f9d7808ba
KAFKA-4469; Fix consumer performance regression from inefficient list removal
and copy
Author: Jason Gustafson
Reviewers: Ismael Juma , Guozhang Wang
Repository: kafka
Updated Branches:
refs/heads/trunk b45a67ede -> ea370be51
KAFKA-4399; Fix deadlock between cleanupGroupMetadata and offset commit
Author: Alexey Ozeritsky
Reviewers: Ismael Juma , Jason Gustafson
Closes
Repository: kafka
Updated Branches:
refs/heads/0.10.1 9ffadbfdc -> 0e20e5fbf
KAFKA-4399; Fix deadlock between cleanupGroupMetadata and offset commit
Author: Alexey Ozeritsky
Reviewers: Ismael Juma , Jason Gustafson
Closes
Repository: kafka
Updated Branches:
refs/heads/trunk b06fc322b -> e43bbce49
KAFKA-4483; Fix NPE in `Log` constructor if log level is INFO or finer
Author: Ismael Juma
Reviewers: Jason Gustafson
Closes #2207 from
Repository: kafka
Updated Branches:
refs/heads/trunk 5819b06fa -> 1503f7603
KAFKA-4387; KafkaConsumer should properly handle interrupts
See https://issues.apache.org/jira/browse/KAFKA-4387
Author: Stig Rohde Døssing
Reviewers: Ismael Juma , Jason
Repository: kafka
Updated Branches:
refs/heads/trunk d98ca230a -> 5819b06fa
KAFKA-4403; Update KafkaBasedLog to use new endOffsets consumer API
ewencp plz review
Author: Balint Molnar
Reviewers: Jason Gustafson
Closes #2176 from
Repository: kafka
Updated Branches:
refs/heads/trunk ce1cb329d -> 6d6c77a7a
http://git-wip-us.apache.org/repos/asf/kafka/blob/6d6c77a7/core/src/main/scala/kafka/log/LogSegment.scala
--
diff --git
MINOR: Improvements to Record related classes (part 1)
Jason recently cleaned things up significantly by consolidating the
Message/Record classes
into the common Java code in the clients module. While reviewing that, I
noticed a few things
that could be improved a little more. To make reviewing
Repository: kafka
Updated Branches:
refs/heads/trunk 7f22ab655 -> a565a77b1
KAFKA-4404; Add javadocs to document core Connect types, especially that
integer types are signed
Author: Ewen Cheslack-Postava
Reviewers: Konstantine Karantasis , Jason
Repository: kafka
Updated Branches:
refs/heads/trunk a565a77b1 -> b565dd7eb
KAFKA-4429; Consumer lag metric should be zero if FetchResponse is empty
Author: Dong Lin
Reviewers: Ewen Cheslack-Postava , Jason Gustafson
Closes #2155
Repository: kafka
Updated Branches:
refs/heads/trunk 7f4b278c0 -> 3930dd7e7
KAFKA-4554; Fix ReplicaBuffer.verifyChecksum to use iterators instead of
iterables
This was changed in b58b6a1bef0 and caused the
`ReplicaVerificationToolTest.test_replica_lags`
system test to start failing.
I also
Repository: kafka
Updated Branches:
refs/heads/trunk 0f86dbe89 -> 68f204e01
http://git-wip-us.apache.org/repos/asf/kafka/blob/68f204e0/core/src/test/scala/unit/kafka/server/BaseReplicaFetchTest.scala
--
diff --git
http://git-wip-us.apache.org/repos/asf/kafka/blob/68f204e0/core/src/main/scala/kafka/server/ReplicaManager.scala
--
diff --git a/core/src/main/scala/kafka/server/ReplicaManager.scala
Repository: kafka
Updated Branches:
refs/heads/trunk 65acff32d -> bc9ef716a
KAFKA-4553; Improve round robin assignment in Connect to avoid uneven
distributions of connectors and tasks
Author: Ewen Cheslack-Postava
Reviewers: Konstantine Karantasis
Repository: kafka
Updated Branches:
refs/heads/trunk d348ac92c -> d27e09e60
MINOR: Use method handles instead of reflection for creating Snappy and LZ4
streams
1. Use Initialization-on-demand holder idiom that relies on JVM lazy-loading
instead of explicit initialization check.
2. Method
Repository: kafka
Updated Branches:
refs/heads/trunk 4b3ea062b -> 2e075fe6a
MINOR: Update possible errors in OffsetFetchResponse
Note: None of the use cases for offset fetch would lead to a
`TOPIC_AUTHORIZATION_FAILED` error (fetching offset of an unauthorized
partition would return an
Repository: kafka
Updated Branches:
refs/heads/trunk dd71e4a8d -> 4e92fd5f7
MINOR: Vagrant provisioning fixes
Author: Magnus Edenhill
Reviewers: Jason Gustafson
Closes #2767 from edenhill/harden_provision
Project:
Repository: kafka
Updated Branches:
refs/heads/trunk aea5989d9 -> 6feaa8a58
KAFKA-1449; Use CRC32C for checksum of V2 message format
I manually tested that Crc32CTest and AbstractChecksums pass with JDK 9. I also
verified that `Java9ChecksumFactory` is used in that case.
Author: Ismael Juma
Repository: kafka
Updated Branches:
refs/heads/trunk edb372dca -> a0b8e435c
MINOR: Support streaming decompression of fetched records for new format
Author: Jason Gustafson
Reviewers: Apurva Mehta , Guozhang Wang
Closes #2738
Repository: kafka
Updated Branches:
refs/heads/trunk 1abed91bd -> f3f9a9eaf
KAFKA-4569; Check for wakeup on every call to KafkaConsumer.poll
Author: Armin Braun
Reviewers: Ismael Juma , Jason Gustafson
Closes #2699 from
201 - 300 of 2118 matches
Mail list logo