[3/4] kafka-site git commit: Resync 0.10.1 documentation

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:

kafka-site git commit: update htaccess to load images nested inside of doc folders

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:

kafka git commit: MINOR: Add images missing from documentation

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:

kafka git commit: MINOR: Add images missing from documentation

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

kafka git commit: KAFKA-4349; Handle 'PreparingRebalance' and 'AwaitingSync' states in consumer group describe

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

kafka git commit: MINOR: Fix regex on connector path param in ConnectorsResource

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 ,

kafka git commit: MINOR: Replaced unnecessary map and getOrElse with exists

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:

kafka-site git commit: Resync 0.10.1 for 0.10.1.0 release

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:

kafka git commit: MINOR: Fixed incomplete sentence in introduction docs

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

kafka git commit: KAFKA-4303; Ensure commitSync does not block unnecessarily in poll without in-flight requests

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

kafka git commit: KAFKA-4303; Ensure commitSync does not block unnecessarily in poll without in-flight requests

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

[kafka] Git Push Summary

Repository: kafka Updated Tags: refs/tags/0.10.1.0-rc3 [created] 50f30a44f

[4/4] kafka-site git commit: Resync 0.10.1 docs for RC3

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:

[2/4] kafka-site git commit: Resync 0.10.1 docs for RC3

http://git-wip-us.apache.org/repos/asf/kafka-site/blob/230d32e6/0101/javadoc/org/apache/kafka/common/serialization/Serdes.ByteArraySerde.html -- diff --git

[3/4] kafka-site git commit: Resync 0.10.1 docs for RC3

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

[1/4] kafka-site git commit: Resync 0.10.1 docs for RC3

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

kafka git commit: MINOR: Code refactor - cleaning up some boolean assignments

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

kafka git commit: KAFKA-4310; Add missing Windows script `kafka-consumer-groups.bat`

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

[2/2] kafka-site git commit: Update download page for 0.10.1.0

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:

[1/2] kafka-site git commit: Enable 0.10.1 documentation

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:

kafka git commit: KAFKA-4296; Fix LogCleaner statistics rolling

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:

kafka git commit: MINOR: Fix vagrant rsync exclude argument

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

kafka git commit: KAFKA-4319; Parallelize shutdown of fetchers in AbstractFetcherManager to speedup shutdown

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

svn commit: r16588 - in /dev/kafka/0.10.1.0: ./ javadoc/ javadoc/org/ javadoc/org/apache/ javadoc/org/apache/kafka/ javadoc/org/apache/kafka/clients/ javadoc/org/apache/kafka/clients/consumer/ javadoc

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.]

[kafka] Git Push Summary

Repository: kafka Updated Tags: refs/tags/0.10.1.0 [created] 88d865799

[1/2] kafka git commit: Bump version to 0.10.1.1-SNAPSHOT

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:

[2/2] kafka git commit: Bump version to 0.10.1.0

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:

kafka git commit: MINOR: Remove duplicate doc headers

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

kafka git commit: MINOR: Remove duplicate doc headers

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:

[1/5] kafka git commit: KAFKA-2066; Use client-side FetchRequest/FetchResponse on server

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

[4/5] kafka git commit: KAFKA-2066; Use client-side FetchRequest/FetchResponse on server

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

[3/5] kafka git commit: KAFKA-2066; Use client-side FetchRequest/FetchResponse on server

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

[2/5] kafka git commit: KAFKA-2066; Use client-side FetchRequest/FetchResponse on server

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

[5/5] kafka git commit: KAFKA-2066; Use client-side FetchRequest/FetchResponse on server

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:

kafka git commit: KAFKA-4081; KafkaConsumer should not allow negative offsets to be committed

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

kafka git commit: MINOR: Remove unused `ByteBoundedBlockingQueue` class and `zkSessionTimeout` parameter

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

kafka git commit: MINOR: Fix issue in `AsyncProducerTest` where it expects the `port` config to be set

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

kafka git commit: KAFKA-4357; Fix consumer group describe output when there is no active member (old consumer)

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

kafka git commit: MINOR: Increase zk connection timeout in tests for client created in `KafkaServer`

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

kafka git commit: KAFKA-4024; Override client metadata backoff on topic changes and avoid unnecessary connections

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

kafka git commit: MINOR: Replaced unnecessary isDefined and get on option values with fold

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:

kafka git commit: KAFKA-4130; Link to Varnish architect notes is broken

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

kafka git commit: KAFKA-4130; Link to Varnish architect notes is broken

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:

kafka git commit: MINOR: Fixed broken links in the documentation

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:

kafka git commit: MINOR: Fixed broken links in the documentation

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

kafka git commit: KAFKA-4254; Update producer's metadata before failing on non-existent partitions

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

kafka git commit: KAFKA-4254; Update producer's metadata before failing on non-existent partitions

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

kafka git commit: KAFKA-4298; Ensure compressed message sets are not converted when log cleaning

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

kafka git commit: MINOR: Make documentation follow latest template

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

[1/3] kafka git commit: MINOR: Fix typos in documentation

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

[3/3] kafka git commit: MINOR: Fix typos in documentation

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:

[3/3] kafka git commit: MINOR: Fix typos in documentation

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

kafka git commit: MINOR: Fix table of contents and section numbers in the documentation

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

kafka git commit: MINOR: Fix table of contents and section numbers in the documentation

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

kafka git commit: MINOR: Make documentation follow latest template

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

kafka-site git commit: Additional doc fixes for 0.10.1

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:

[3/4] kafka-site git commit: Resync 0.10.1 docs for RC2

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

[2/4] kafka-site git commit: Resync 0.10.1 docs for RC2

http://git-wip-us.apache.org/repos/asf/kafka-site/blob/a6986e07/0101/javadoc/org/apache/kafka/common/serialization/Serdes.ByteBufferSerde.html -- diff --git

[4/4] kafka-site git commit: Resync 0.10.1 docs for RC2

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:

[1/9] kafka git commit: KAFKA-4390; Replace MessageSet usage with client-side alternatives

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

[2/9] kafka git commit: KAFKA-4390; Replace MessageSet usage with client-side alternatives

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

[7/9] kafka git commit: KAFKA-4390; Replace MessageSet usage with client-side alternatives

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

[3/9] kafka git commit: KAFKA-4390; Replace MessageSet usage with client-side alternatives

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

[4/9] kafka git commit: KAFKA-4390; Replace MessageSet usage with client-side alternatives

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

[9/9] kafka git commit: KAFKA-4390; Replace MessageSet usage with client-side alternatives

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:

[8/9] kafka git commit: KAFKA-4390; Replace MessageSet usage with client-side alternatives

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

[6/9] kafka git commit: KAFKA-4390; Replace MessageSet usage with client-side alternatives

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

[5/9] kafka git commit: KAFKA-4390; Replace MessageSet usage with client-side alternatives

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

[1/2] kafka git commit: MINOR: Replace deepIterator/shallowIterator with deepEntries/shallowEntries

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

kafka git commit: KAFKA-4405; Avoid unnecessary network poll in consumer if no fetches sent

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

kafka git commit: MINOR: Fix typos in KafkaConsumer docs

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:

kafka git commit: KAFKA-4272; Add missing 'connect' Windows batch scripts

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:

kafka git commit: KAFKA-4375; Reset interrupt state in a few places where InterruptedException is caught

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

[2/3] kafka git commit: KAFKA-4565; Separation of Internal and External traffic (KIP-103)

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

[3/3] kafka git commit: KAFKA-4565; Separation of Internal and External traffic (KIP-103)

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:

[1/3] kafka git commit: KAFKA-4565; Separation of Internal and External traffic (KIP-103)

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

kafka git commit: KAFKA-4627; Fix timing issue in consumer close tests

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

[1/2] kafka git commit: KAFKA-3853; Extend OffsetFetch API to allow fetching all offsets for a consumer group (KIP-88)

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

kafka git commit: KAFKA-4426; Add close with timeout for KafkaConsumer (KIP-102)

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

kafka git commit: KAFKA-4469; Fix consumer performance regression from inefficient list removal and copy

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

kafka git commit: KAFKA-4469; Fix consumer performance regression from inefficient list removal and copy

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

kafka git commit: KAFKA-4399; Fix deadlock between cleanupGroupMetadata and offset commit

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

kafka git commit: KAFKA-4399; Fix deadlock between cleanupGroupMetadata and offset commit

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

kafka git commit: KAFKA-4483; Fix NPE in `Log` constructor if log level is INFO or finer

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

kafka git commit: KAFKA-4387; KafkaConsumer should properly handle interrupts

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

kafka git commit: KAFKA-4403; Update KafkaBasedLog to use new endOffsets consumer API

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

[1/2] kafka git commit: MINOR: Improvements to Record related classes (part 1)

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

[2/2] kafka git commit: MINOR: Improvements to Record related classes (part 1)

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

kafka git commit: KAFKA-4404; Add javadocs to document core Connect types, especially that integer types are signed

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

kafka git commit: KAFKA-4429; Consumer lag metric should be zero if FetchResponse is empty

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

kafka git commit: KAFKA-4554; Fix ReplicaBuffer.verifyChecksum to use iterators instead of iterables

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

[1/3] kafka git commit: MINOR: Replace TopicAndPartition with TopicPartition in `Log` and `ReplicaManager`

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

[2/3] kafka git commit: MINOR: Replace TopicAndPartition with TopicPartition in `Log` and `ReplicaManager`

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

kafka git commit: KAFKA-4553; Improve round robin assignment in Connect to avoid uneven distributions of connectors and tasks

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

kafka git commit: MINOR: Use method handles instead of reflection for creating Snappy and LZ4 streams

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

kafka git commit: MINOR: Update possible errors in OffsetFetchResponse

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

kafka git commit: MINOR: Vagrant provisioning fixes

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:

kafka git commit: KAFKA-1449; Use CRC32C for checksum of V2 message format

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

kafka git commit: MINOR: Support streaming decompression of fetched records for new format

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

kafka git commit: KAFKA-4569; Check for wakeup on every call to KafkaConsumer.poll

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

<    1   2   3   4   5   6   7   8   9   10   >