kafka git commit: HOTFIX: Verifiable producer request timeout needs conversion to milliseconds

2017-02-03 Thread jgus
Repository: kafka Updated Branches: refs/heads/trunk 7ebc5da60 -> 88809b9b8 HOTFIX: Verifiable producer request timeout needs conversion to milliseconds Author: Jason Gustafson Reviewers: Ewen Cheslack-Postava Closes #2494 from

kafka git commit: HOTFIX: Do Not use unlimited num messages in IntegrationTestUtils

2017-02-06 Thread jgus
Repository: kafka Updated Branches: refs/heads/trunk 82e75b960 -> 2c0055e62 HOTFIX: Do Not use unlimited num messages in IntegrationTestUtils Removed readKeyValues() that give UNLIMITED_MESSAGES which will doom to exhaust all wait time, as all its callers actually do provide the expected

kafka git commit: KAFKA-4749; Fix join-time-max and sync-time-max MeasurableStat type

2017-02-08 Thread jgus
Repository: kafka Updated Branches: refs/heads/trunk 8bd8751aa -> 6c1478d19 KAFKA-4749; Fix join-time-max and sync-time-max MeasurableStat type GroupCoordinatorMetrics currently sets up join-time-max and sync-time-max incorrectly as a "new Avg()" MeasurableStat instead of "new Max()"

kafka git commit: KAFKA-4728; KafkaConsumer#commitSync should copy its input

2017-02-06 Thread jgus
Repository: kafka Updated Branches: refs/heads/trunk 1f8a2ad2e -> b31a7a902 KAFKA-4728; KafkaConsumer#commitSync should copy its input Author: Jan Lukavsky Reviewers: Jason Gustafson Closes #2491 from je-ik/KAFKA-4728 Project:

kafka git commit: KAFKA-4728; KafkaConsumer#commitSync should copy its input

2017-02-06 Thread jgus
Repository: kafka Updated Branches: refs/heads/0.10.2 e321cd4f5 -> f4276b7cf KAFKA-4728; KafkaConsumer#commitSync should copy its input Author: Jan Lukavsky Reviewers: Jason Gustafson Closes #2491 from je-ik/KAFKA-4728 (cherry picked from commit

kafka git commit: MINOR: Update docs for version 0.10.2.0

2017-02-01 Thread jgus
Repository: kafka Updated Branches: refs/heads/trunk 0b48ea1c8 -> cea461353 MINOR: Update docs for version 0.10.2.0 Author: Ewen Cheslack-Postava Reviewers: Jason Gustafson Closes #2480 from ewencp/docs-version-0.10.2.0 Project:

kafka git commit: MINOR: Update docs for version 0.10.2.0

2017-02-01 Thread jgus
Repository: kafka Updated Branches: refs/heads/0.10.2 54512cbaf -> 9cf6f9790 MINOR: Update docs for version 0.10.2.0 Author: Ewen Cheslack-Postava Reviewers: Jason Gustafson Closes #2480 from ewencp/docs-version-0.10.2.0 (cherry picked from commit

kafka git commit: MINOR: Logging improvements in consumer internals

2017-01-31 Thread jgus
Repository: kafka Updated Branches: refs/heads/trunk b948f4327 -> 5afe95964 MINOR: Logging improvements in consumer internals Author: Jason Gustafson Reviewers: Manikumar reddy O , Ewen Cheslack-Postava , Ismael Juma

kafka git commit: MINOR: Logging improvements in consumer internals

2017-01-31 Thread jgus
Repository: kafka Updated Branches: refs/heads/0.10.2 61024c9d2 -> a50635219 MINOR: Logging improvements in consumer internals Author: Jason Gustafson Reviewers: Manikumar reddy O , Ewen Cheslack-Postava , Ismael Juma

[2/2] kafka git commit: KAFKA-4633; Always using regex pattern subscription in StreamThread

2017-01-23 Thread jgus
KAFKA-4633; Always using regex pattern subscription in StreamThread 1. In StreamThread, always use subscribe(Pattern, ..) function in order to avoid sending MetadataRequest with specific topic names and cause brokers to possibly auto-create subscribed topics; the pattern is generated as

[1/2] kafka git commit: KAFKA-4633; Always using regex pattern subscription in StreamThread

2017-01-23 Thread jgus
Repository: kafka Updated Branches: refs/heads/trunk 62206de4e -> 3400d0c3c http://git-wip-us.apache.org/repos/asf/kafka/blob/3400d0c3/streams/src/main/java/org/apache/kafka/streams/processor/TopologyBuilder.java -- diff --git

[1/2] kafka git commit: KAFKA-4633; Always using regex pattern subscription in StreamThread

2017-01-23 Thread jgus
Repository: kafka Updated Branches: refs/heads/0.10.2 80ceb75d2 -> 0f87991d5 http://git-wip-us.apache.org/repos/asf/kafka/blob/0f87991d/streams/src/main/java/org/apache/kafka/streams/processor/TopologyBuilder.java -- diff

kafka git commit: MINOR: Add offset information to consumer_test error messages

2017-01-23 Thread jgus
Repository: kafka Updated Branches: refs/heads/trunk 79987590e -> bf5aebadb MINOR: Add offset information to consumer_test error messages Author: Jason Gustafson Reviewers: Ismael Juma Closes #2426 from hachikuji/improve-consumer-test-error-messages

kafka git commit: KAFKA-4699; Invoke producer callbacks before completing the future

2017-01-26 Thread jgus
Repository: kafka Updated Branches: refs/heads/trunk 5b4e299a4 -> 254e3b77d KAFKA-4699; Invoke producer callbacks before completing the future This behaviour was changed in 8b3c6c0, but it caused interceptor test failures (which rely on callbacks) and since we’re so close to code freeze,

kafka git commit: KAFKA-4699; Invoke producer callbacks before completing the future

2017-01-26 Thread jgus
Repository: kafka Updated Branches: refs/heads/0.10.2 8812d151a -> 29bc8905a KAFKA-4699; Invoke producer callbacks before completing the future This behaviour was changed in 8b3c6c0, but it caused interceptor test failures (which rely on callbacks) and since we’re so close to code freeze,

kafka git commit: MINOR: Close create topics policy during shutdown and more tests

2017-01-26 Thread jgus
Repository: kafka Updated Branches: refs/heads/0.10.2 5f1ab1419 -> b2bcef7f3 MINOR: Close create topics policy during shutdown and more tests Author: Ismael Juma Reviewers: Jason Gustafson Closes #2443 from

kafka git commit: KAFKA-4698; VerifyError in kafka/client/ClientUtils due to -target:jvm-1.7

2017-01-25 Thread jgus
Repository: kafka Updated Branches: refs/heads/trunk 0971e62e5 -> 23f695196 KAFKA-4698; VerifyError in kafka/client/ClientUtils due to -target:jvm-1.7 Author: Ismael Juma Reviewers: Jason Gustafson Closes #2434 from

kafka git commit: KAFKA-4698; VerifyError in kafka/client/ClientUtils due to -target:jvm-1.7

2017-01-25 Thread jgus
Repository: kafka Updated Branches: refs/heads/0.10.2 1d2426683 -> 94c0da2b7 KAFKA-4698; VerifyError in kafka/client/ClientUtils due to -target:jvm-1.7 Author: Ismael Juma Reviewers: Jason Gustafson Closes #2434 from

kafka git commit: KAFKA-4597; RecordMetadata should return log append time when appropriate

2017-01-25 Thread jgus
Repository: kafka Updated Branches: refs/heads/0.10.2 94c0da2b7 -> e74a92463 KAFKA-4597; RecordMetadata should return log append time when appropriate There is a slight change of behaviour: we now complete the `Future` returned from `send` before the callbacks are invoked. This seems OK and

kafka git commit: MINOR: Change logging level for ignored maybeAddMetric from debug to trace

2017-01-26 Thread jgus
Repository: kafka Updated Branches: refs/heads/trunk 0c83eddcd -> 1eac3f33f MINOR: Change logging level for ignored maybeAddMetric from debug to trace Author: Guozhang Wang Reviewers: Eno Thereska , Xavier Léauté , Jason

kafka git commit: MINOR: Change logging level for ignored maybeAddMetric from debug to trace

2017-01-26 Thread jgus
Repository: kafka Updated Branches: refs/heads/0.10.2 f68c7e0f3 -> af4f4df18 MINOR: Change logging level for ignored maybeAddMetric from debug to trace Author: Guozhang Wang Reviewers: Eno Thereska , Xavier Léauté , Jason

kafka git commit: KAFKA-4547; Avoid unnecessary offset commit that could lead to an invalid offset position if partition is paused

2017-01-24 Thread jgus
Repository: kafka Updated Branches: refs/heads/0.10.1 027455146 -> c310a1bc6 KAFKA-4547; Avoid unnecessary offset commit that could lead to an invalid offset position if partition is paused Author: Vahid Hashemian Reviewers: Jason Gustafson

[5/5] kafka git commit: MINOR: Remove Struct from Request/Response classes

2017-02-17 Thread jgus
MINOR: Remove Struct from Request/Response classes More details: * Replaced `struct` field in Request/Response with a `toStruct` method. This makes the performance model (including memory usage) easier to understand. Note that requests have `toStruct()` while responses have `toStruct(version)`. *

[1/5] kafka git commit: MINOR: Remove Struct from Request/Response classes

2017-02-17 Thread jgus
Repository: kafka Updated Branches: refs/heads/trunk 1f2ee5f0a -> fc1cfe475 http://git-wip-us.apache.org/repos/asf/kafka/blob/fc1cfe47/core/src/test/scala/unit/kafka/server/BaseRequestTest.scala -- diff --git

[4/5] kafka git commit: MINOR: Remove Struct from Request/Response classes

2017-02-17 Thread jgus
http://git-wip-us.apache.org/repos/asf/kafka/blob/fc1cfe47/clients/src/main/java/org/apache/kafka/common/requests/FetchResponse.java -- diff --git a/clients/src/main/java/org/apache/kafka/common/requests/FetchResponse.java

[2/5] kafka git commit: MINOR: Remove Struct from Request/Response classes

2017-02-17 Thread jgus
http://git-wip-us.apache.org/repos/asf/kafka/blob/fc1cfe47/clients/src/test/java/org/apache/kafka/clients/consumer/internals/FetcherTest.java -- diff --git

[3/5] kafka git commit: MINOR: Remove Struct from Request/Response classes

2017-02-17 Thread jgus
http://git-wip-us.apache.org/repos/asf/kafka/blob/fc1cfe47/clients/src/main/java/org/apache/kafka/common/requests/OffsetCommitRequest.java -- diff --git

kafka git commit: MINOR: Move compression stream construction into CompressionType

2017-02-16 Thread jgus
Repository: kafka Updated Branches: refs/heads/trunk 6c839395b -> 022d2017a MINOR: Move compression stream construction into CompressionType Author: Jason Gustafson Reviewers: Ismael Juma Closes #2536 from

kafka git commit: HOTFIX: ClassCastException in request logging

2017-02-17 Thread jgus
Repository: kafka Updated Branches: refs/heads/trunk 1f1e794ad -> a515e9357 HOTFIX: ClassCastException in request logging Author: Jason Gustafson Reviewers: Colin P. Mccabe , Ewen Cheslack-Postava Closes #2566 from

kafka git commit: KAFKA-4786; Wait for heartbeat thread to terminate in consumer close

2017-02-22 Thread jgus
Repository: kafka Updated Branches: refs/heads/trunk 913c09e4a -> 5916ef022 KAFKA-4786; Wait for heartbeat thread to terminate in consumer close Author: Rajini Sivaram Reviewers: Apurva Mehta , Ismael Juma , Jason

kafka git commit: KAFKA-4786; Wait for heartbeat thread to terminate in consumer close

2017-02-22 Thread jgus
Repository: kafka Updated Branches: refs/heads/0.10.2 c231f5280 -> ba4eafa78 KAFKA-4786; Wait for heartbeat thread to terminate in consumer close Author: Rajini Sivaram Reviewers: Apurva Mehta , Ismael Juma , Jason

kafka git commit: MINOR: Fix transient failure of testCannotSendToInternalTopic

2017-02-24 Thread jgus
Repository: kafka Updated Branches: refs/heads/trunk 151b23689 -> 0483a0b0b MINOR: Fix transient failure of testCannotSendToInternalTopic It’s a simple matter of creating the internal topic before trying to send to it. Otherwise, we could get an `UnknownTopicOrPartitionException` in some

kafka git commit: MINOR: Ensure consumer calls poll() if requests are outstanding

2017-02-24 Thread jgus
Repository: kafka Updated Branches: refs/heads/0.10.2 ac05c343a -> a9f4b671f MINOR: Ensure consumer calls poll() if requests are outstanding Author: Jason Gustafson Reviewers: Onur Karaman , Ismael Juma Closes #2596 from

kafka git commit: MINOR: Make it impossible to invoke `Request.body` without an explicit type parameter

2017-02-24 Thread jgus
Repository: kafka Updated Branches: refs/heads/trunk 43524442d -> b917af190 MINOR: Make it impossible to invoke `Request.body` without an explicit type parameter Author: Ismael Juma Reviewers: Jason Gustafson Closes #2579 from ijuma/safer-body

kafka git commit: MINOR: Ensure consumer calls poll() if requests are outstanding

2017-02-24 Thread jgus
Repository: kafka Updated Branches: refs/heads/trunk b917af190 -> 374983263 MINOR: Ensure consumer calls poll() if requests are outstanding Author: Jason Gustafson Reviewers: Onur Karaman , Ismael Juma Closes #2596 from

kafka git commit: MINOR: Fixed Non-Final Close Method + its Duplication

2017-02-24 Thread jgus
Repository: kafka Updated Branches: refs/heads/trunk 0483a0b0b -> 43524442d MINOR: Fixed Non-Final Close Method + its Duplication Author: Armin Braun Reviewers: Ismael Juma , Jason Gustafson Closes #2582 from

[2/2] kafka git commit: MINOR: Move ProtoUtils methods to ApiKeys

2017-02-22 Thread jgus
MINOR: Move ProtoUtils methods to ApiKeys Also move `requireTimestamp` to `minVersion` logic from `Fetcher` to `ListOffsetRequest.Builder.forConsumer()`. Author: Ismael Juma Reviewers: Colin P. Mccabe , Jason Gustafson Closes

[1/2] kafka git commit: MINOR: Move ProtoUtils methods to ApiKeys

2017-02-22 Thread jgus
Repository: kafka Updated Branches: refs/heads/trunk 5916ef022 -> 015f1d738 http://git-wip-us.apache.org/repos/asf/kafka/blob/015f1d73/clients/src/main/java/org/apache/kafka/common/requests/OffsetFetchResponse.java -- diff

kafka git commit: KAFKA-4776; Implement graceful handling for improperly formed compressed message sets

2017-02-19 Thread jgus
Repository: kafka Updated Branches: refs/heads/trunk 3db3d73de -> e41e78200 KAFKA-4776; Implement graceful handling for improperly formed compressed message sets Author: Jason Gustafson Reviewers: Jiangjie Qin Closes #2572 from

kafka git commit: HOTFIX: ClassCastException in Request error logging

2017-02-18 Thread jgus
Repository: kafka Updated Branches: refs/heads/trunk dcea49856 -> d24d932ef HOTFIX: ClassCastException in Request error logging Fixed ClassCastException resulting from missing type hint in request logging. Author: Armin Braun Reviewers: Jason Gustafson

kafka git commit: KAFKA-4777; Backoff properly in consumer heartbeat thread if no brokers are available

2017-02-18 Thread jgus
Repository: kafka Updated Branches: refs/heads/trunk 916edc3a4 -> dcea49856 KAFKA-4777; Backoff properly in consumer heartbeat thread if no brokers are available Author: Allen Xiang Reviewers: Jason Gustafson Closes #2564 from

kafka git commit: KAFKA-4761; Fix producer regression handling small or zero batch size

2017-02-13 Thread jgus
Repository: kafka Updated Branches: refs/heads/0.10.2 dfbe944e9 -> 71a511c34 KAFKA-4761; Fix producer regression handling small or zero batch size Author: Jason Gustafson Reviewers: Apurva Mehta , Vahid Hashemian ,

[5/5] kafka git commit: MINOR: Use an explicit `Errors` object when possible instead of a numeric error code

2017-02-09 Thread jgus
MINOR: Use an explicit `Errors` object when possible instead of a numeric error code Author: Vahid Hashemian Reviewers: Ismael Juma , Jason Gustafson Closes #2475 from

[3/5] kafka git commit: MINOR: Use an explicit `Errors` object when possible instead of a numeric error code

2017-02-09 Thread jgus
http://git-wip-us.apache.org/repos/asf/kafka/blob/9898d665/clients/src/test/java/org/apache/kafka/clients/consumer/internals/FetcherTest.java -- diff --git

[4/5] kafka git commit: MINOR: Use an explicit `Errors` object when possible instead of a numeric error code

2017-02-09 Thread jgus
http://git-wip-us.apache.org/repos/asf/kafka/blob/9898d665/clients/src/main/java/org/apache/kafka/common/requests/UpdateMetadataResponse.java -- diff --git

[1/5] kafka git commit: MINOR: Use an explicit `Errors` object when possible instead of a numeric error code

2017-02-09 Thread jgus
Repository: kafka Updated Branches: refs/heads/trunk a15fcea79 -> 9898d665d http://git-wip-us.apache.org/repos/asf/kafka/blob/9898d665/core/src/test/scala/unit/kafka/coordinator/GroupCoordinatorResponseTest.scala -- diff --git

kafka git commit: KAFKA-4758; Connect missing checks for NO_TIMESTAMP

2017-02-12 Thread jgus
Repository: kafka Updated Branches: refs/heads/trunk 260d487cd -> 5dabca025 KAFKA-4758; Connect missing checks for NO_TIMESTAMP Author: rnpridgeon Reviewers: Ewen Cheslack-Postava , Jason Gustafson Closes #2533 from

kafka git commit: MINOR: Some cleanups and additional testing for KIP-88

2017-01-17 Thread jgus
Repository: kafka Updated Branches: refs/heads/trunk 55abe65e0 -> 7a84b241e MINOR: Some cleanups and additional testing for KIP-88 Author: Jason Gustafson Reviewers: Vahid Hashemian , Ismael Juma Closes #2383 from

kafka git commit: KAFKA-3502; move RocksDB options construction to init()

2017-01-17 Thread jgus
Repository: kafka Updated Branches: refs/heads/trunk fd6d7bcf3 -> 1974e1b0e KAFKA-3502; move RocksDB options construction to init() In RocksDBStore, options / wOptions / fOptions are constructed in the constructor, which needs to be dismissed in the close() call; however in some tests, the

kafka git commit: KAFKA-3502; move RocksDB options construction to init()

2017-01-17 Thread jgus
Repository: kafka Updated Branches: refs/heads/0.10.2 eb62e5695 -> e38794e02 KAFKA-3502; move RocksDB options construction to init() In RocksDBStore, options / wOptions / fOptions are constructed in the constructor, which needs to be dismissed in the close() call; however in some tests, the

kafka git commit: KAFKA-4547; Avoid incorrect reset of paused partitions to the committed offsets

2017-01-19 Thread jgus
Repository: kafka Updated Branches: refs/heads/trunk 5fc530bc4 -> 813897a00 KAFKA-4547; Avoid incorrect reset of paused partitions to the committed offsets Author: Vahid Hashemian Reviewers: Jason Gustafson Closes #2341 from

kafka git commit: KAFKA-4547; Avoid incorrect reset of paused partitions to the committed offsets

2017-01-19 Thread jgus
Repository: kafka Updated Branches: refs/heads/0.10.2 770bab399 -> 17dd4db29 KAFKA-4547; Avoid incorrect reset of paused partitions to the committed offsets Author: Vahid Hashemian Reviewers: Jason Gustafson Closes #2341 from

kafka git commit: MINOR: Document that Connect topics should use compaction

2016-09-07 Thread jgus
Repository: kafka Updated Branches: refs/heads/trunk 3a244b783 -> ca3f3a492 MINOR: Document that Connect topics should use compaction Update documentation for Kafka Connect distributed’s config.storage.topic, offset.storage.topic, and status.storage.topic configuration values to indicate

kafka git commit: KAFKA-4139; Reset findCoordinatorFuture when brokers are unavailable

2016-09-08 Thread jgus
Repository: kafka Updated Branches: refs/heads/trunk 69ebf6f7b -> 6cf2cb6f2 KAFKA-4139; Reset findCoordinatorFuture when brokers are unavailable Author: Rajini Sivaram Reviewers: Ismael Juma, Jason Gustafson Closes #1831 from rajinisivaram/KAFKA-4139

kafka git commit: KAFKA-4033; Revise partition assignment semantics on consumer subscription changes (KIP-70)

2016-09-08 Thread jgus
Repository: kafka Updated Branches: refs/heads/trunk eb59c8124 -> 54767bbba KAFKA-4033; Revise partition assignment semantics on consumer subscription changes (KIP-70) This PR changes topic subscription semantics so a change in subscription does not immediately cause a rebalance. Instead,

kafka git commit: KAFKA-2311; Make KafkaConsumer's ensureNotClosed method thread-safe

2016-09-12 Thread jgus
Repository: kafka Updated Branches: refs/heads/trunk a7ab9cb83 -> 2a660f13d KAFKA-2311; Make KafkaConsumer's ensureNotClosed method thread-safe Here is the patch on github ijuma. Acquiring the consumer lock (the single thread access controls) requires that the consumer be open. I changed

kafka git commit: KAFKA-3831; Prepare for updating new-consumer-based Mirror Maker's default partition assignment strategy to round robin

2016-09-26 Thread jgus
Repository: kafka Updated Branches: refs/heads/0.10.1 823c08067 -> 6b8bcf65e KAFKA-3831; Prepare for updating new-consumer-based Mirror Maker's default partition assignment strategy to round robin This patch adds proper warning message and necessary doc updates for updating the default

kafka git commit: KAFKA-3831; Prepare for updating new-consumer-based Mirror Maker's default partition assignment strategy to round robin

2016-09-26 Thread jgus
Repository: kafka Updated Branches: refs/heads/trunk be6056abc -> 60ad6d727 KAFKA-3831; Prepare for updating new-consumer-based Mirror Maker's default partition assignment strategy to round robin This patch adds proper warning message and necessary doc updates for updating the default

kafka git commit: KAFKA-3697; Clean up website documentation of client usage

2016-09-29 Thread jgus
Repository: kafka Updated Branches: refs/heads/0.10.1 2a059fa68 -> 7de050ee5 KAFKA-3697; Clean up website documentation of client usage This is to imply that the Java consumer/producer are the recommended consumer/producer now. Author: Vahid Hashemian Reviewers:

kafka git commit: KAFKA-3697; Clean up website documentation of client usage

2016-09-29 Thread jgus
Repository: kafka Updated Branches: refs/heads/trunk 7c6d70655 -> d2a267b11 KAFKA-3697; Clean up website documentation of client usage This is to imply that the Java consumer/producer are the recommended consumer/producer now. Author: Vahid Hashemian Reviewers:

kafka-site git commit: theme enhancements for mobile and branding guidelines

2016-10-05 Thread jgus
Repository: kafka-site Updated Branches: refs/heads/asf-site 590fd7083 -> aa684e574 theme enhancements for mobile and branding guidelines rewrite rules added to prevent users from loading up html files meant to be partials add notification over past versions of docs and rename partials

kafka git commit: KAFKA-4165; Add 0.10.0.1 as a source for compatibility tests

2016-10-04 Thread jgus
Repository: kafka Updated Branches: refs/heads/0.10.1 41b12a6ad -> 017defcd1 KAFKA-4165; Add 0.10.0.1 as a source for compatibility tests Author: Jason Gustafson Reviewers: Ismael Juma Closes #1959 from hachikuji/KAFKA-4165 (cherry picked from

kafka git commit: Bump version to 0.10.1.0

2016-10-04 Thread jgus
Repository: kafka Updated Branches: refs/heads/0.10.1 017defcd1 -> e51c4cf99 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/e51c4cf9 Tree:

[kafka] Git Push Summary [forced push!] [Forced Update!]

2016-10-04 Thread jgus
Repository: kafka Updated Branches: refs/heads/0.10.1 e51c4cf99 -> 017defcd1 (forced update)

kafka git commit: MINOR: Tweak upgrade note on KIP-62 to include request.timeout.ms

2016-10-04 Thread jgus
Repository: kafka Updated Branches: refs/heads/trunk 1a396c9cf -> d8d2f3aac MINOR: Tweak upgrade note on KIP-62 to include request.timeout.ms Author: Jason Gustafson Reviewers: Ismael Juma Closes #1960 from hachikuji/add-note-on-request-timeout

kafka git commit: MINOR: Tweak upgrade note on KIP-62 to include request.timeout.ms

2016-10-04 Thread jgus
Repository: kafka Updated Branches: refs/heads/0.10.1 aafc86928 -> 41b12a6ad MINOR: Tweak upgrade note on KIP-62 to include request.timeout.ms Author: Jason Gustafson Reviewers: Ismael Juma Closes #1960 from hachikuji/add-note-on-request-timeout

kafka git commit: KAFKA-4165; Add 0.10.0.1 as a source for compatibility tests

2016-10-04 Thread jgus
Repository: kafka Updated Branches: refs/heads/trunk d8d2f3aac -> b3eef7bc7 KAFKA-4165; Add 0.10.0.1 as a source for compatibility tests Author: Jason Gustafson Reviewers: Ismael Juma Closes #1959 from hachikuji/KAFKA-4165 Project:

kafka git commit: MINOR: Update documentation for 0.10.1 release

2016-10-04 Thread jgus
Repository: kafka Updated Branches: refs/heads/0.10.1 017defcd1 -> f4c186d31 MINOR: Update documentation for 0.10.1 release Author: Jason Gustafson Reviewers: Gwen Shapira Closes #1963 from hachikuji/update-docs-for-0.10.1 Project:

[45/51] [partial] kafka-site git commit: Add 0.10.1 javadocs

2016-10-04 Thread jgus
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/2d621da3/0101/javadoc/org/apache/kafka/clients/consumer/ConsumerConfig.html -- diff --git a/0101/javadoc/org/apache/kafka/clients/consumer/ConsumerConfig.html

[18/51] [partial] kafka-site git commit: Add 0.10.1 javadocs

2016-10-04 Thread jgus
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/2d621da3/0101/javadoc/org/apache/kafka/common/errors/RecordTooLargeException.html -- diff --git a/0101/javadoc/org/apache/kafka/common/errors/RecordTooLargeException.html

[25/51] [partial] kafka-site git commit: Add 0.10.1 javadocs

2016-10-04 Thread jgus
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/2d621da3/0101/javadoc/org/apache/kafka/common/errors/ControllerMovedException.html -- diff --git a/0101/javadoc/org/apache/kafka/common/errors/ControllerMovedException.html

[20/51] [partial] kafka-site git commit: Add 0.10.1 javadocs

2016-10-04 Thread jgus
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/2d621da3/0101/javadoc/org/apache/kafka/common/errors/NetworkException.html -- diff --git a/0101/javadoc/org/apache/kafka/common/errors/NetworkException.html

[07/51] [partial] kafka-site git commit: Add 0.10.1 javadocs

2016-10-04 Thread jgus
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/2d621da3/0101/javadoc/org/apache/kafka/connect/data/Decimal.html -- diff --git a/0101/javadoc/org/apache/kafka/connect/data/Decimal.html

[27/51] [partial] kafka-site git commit: Add 0.10.1 javadocs

2016-10-04 Thread jgus
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/2d621da3/0101/javadoc/org/apache/kafka/common/config/SslConfigs.html -- diff --git a/0101/javadoc/org/apache/kafka/common/config/SslConfigs.html

[10/51] [partial] kafka-site git commit: Add 0.10.1 javadocs

2016-10-04 Thread jgus
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/2d621da3/0101/javadoc/org/apache/kafka/common/serialization/Serdes.html -- diff --git a/0101/javadoc/org/apache/kafka/common/serialization/Serdes.html

[40/51] [partial] kafka-site git commit: Add 0.10.1 javadocs

2016-10-04 Thread jgus
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/2d621da3/0101/javadoc/org/apache/kafka/clients/consumer/OffsetResetStrategy.html -- diff --git a/0101/javadoc/org/apache/kafka/clients/consumer/OffsetResetStrategy.html

[43/51] [partial] kafka-site git commit: Add 0.10.1 javadocs

2016-10-04 Thread jgus
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/2d621da3/0101/javadoc/org/apache/kafka/clients/consumer/KafkaConsumer.html -- diff --git a/0101/javadoc/org/apache/kafka/clients/consumer/KafkaConsumer.html

[04/51] [partial] kafka-site git commit: Add 0.10.1 javadocs

2016-10-04 Thread jgus
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/2d621da3/0101/javadoc/org/apache/kafka/connect/data/Struct.html -- diff --git a/0101/javadoc/org/apache/kafka/connect/data/Struct.html

[38/51] [partial] kafka-site git commit: Add 0.10.1 javadocs

2016-10-04 Thread jgus
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/2d621da3/0101/javadoc/org/apache/kafka/clients/producer/KafkaProducer.html -- diff --git a/0101/javadoc/org/apache/kafka/clients/producer/KafkaProducer.html

[15/51] [partial] kafka-site git commit: Add 0.10.1 javadocs

2016-10-04 Thread jgus
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/2d621da3/0101/javadoc/org/apache/kafka/common/errors/package-frame.html -- diff --git a/0101/javadoc/org/apache/kafka/common/errors/package-frame.html

[01/51] [partial] kafka-site git commit: Add 0.10.1 javadocs

2016-10-04 Thread jgus
Repository: kafka-site Updated Branches: refs/heads/asf-site ed0bb0d98 -> 2d621da3b http://git-wip-us.apache.org/repos/asf/kafka-site/blob/2d621da3/0101/javadoc/org/apache/kafka/connect/sink/SinkConnector.html -- diff --git

[22/51] [partial] kafka-site git commit: Add 0.10.1 javadocs

2016-10-04 Thread jgus
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/2d621da3/0101/javadoc/org/apache/kafka/common/errors/InvalidOffsetException.html -- diff --git a/0101/javadoc/org/apache/kafka/common/errors/InvalidOffsetException.html

[39/51] [partial] kafka-site git commit: Add 0.10.1 javadocs

2016-10-04 Thread jgus
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/2d621da3/0101/javadoc/org/apache/kafka/clients/consumer/package-summary.html -- diff --git a/0101/javadoc/org/apache/kafka/clients/consumer/package-summary.html

[06/51] [partial] kafka-site git commit: Add 0.10.1 javadocs

2016-10-04 Thread jgus
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/2d621da3/0101/javadoc/org/apache/kafka/connect/data/Schema.html -- diff --git a/0101/javadoc/org/apache/kafka/connect/data/Schema.html

[37/51] [partial] kafka-site git commit: Add 0.10.1 javadocs

2016-10-04 Thread jgus
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/2d621da3/0101/javadoc/org/apache/kafka/clients/producer/MockProducer.html -- diff --git a/0101/javadoc/org/apache/kafka/clients/producer/MockProducer.html

[35/51] [partial] kafka-site git commit: Add 0.10.1 javadocs

2016-10-04 Thread jgus
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/2d621da3/0101/javadoc/org/apache/kafka/clients/producer/ProducerRecord.html -- diff --git a/0101/javadoc/org/apache/kafka/clients/producer/ProducerRecord.html

[28/51] [partial] kafka-site git commit: Add 0.10.1 javadocs

2016-10-04 Thread jgus
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/2d621da3/0101/javadoc/org/apache/kafka/common/config/ConfigException.html -- diff --git a/0101/javadoc/org/apache/kafka/common/config/ConfigException.html

[12/51] [partial] kafka-site git commit: Add 0.10.1 javadocs

2016-10-04 Thread jgus
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/2d621da3/0101/javadoc/org/apache/kafka/common/serialization/LongDeserializer.html -- diff --git a/0101/javadoc/org/apache/kafka/common/serialization/LongDeserializer.html

[26/51] [partial] kafka-site git commit: Add 0.10.1 javadocs

2016-10-04 Thread jgus
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/2d621da3/0101/javadoc/org/apache/kafka/common/errors/ApiException.html -- diff --git a/0101/javadoc/org/apache/kafka/common/errors/ApiException.html

[14/51] [partial] kafka-site git commit: Add 0.10.1 javadocs

2016-10-04 Thread jgus
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/2d621da3/0101/javadoc/org/apache/kafka/common/serialization/ByteArraySerializer.html -- diff --git

[48/51] [partial] kafka-site git commit: Add 0.10.1 javadocs

2016-10-04 Thread jgus
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/2d621da3/0101/javadoc/deprecated-list.html -- diff --git a/0101/javadoc/deprecated-list.html b/0101/javadoc/deprecated-list.html new file mode 100644 index 000..1aed704

[36/51] [partial] kafka-site git commit: Add 0.10.1 javadocs

2016-10-04 Thread jgus
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/2d621da3/0101/javadoc/org/apache/kafka/clients/producer/ProducerConfig.html -- diff --git a/0101/javadoc/org/apache/kafka/clients/producer/ProducerConfig.html

[08/51] [partial] kafka-site git commit: Add 0.10.1 javadocs

2016-10-04 Thread jgus
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/2d621da3/0101/javadoc/org/apache/kafka/connect/connector/Task.html -- diff --git a/0101/javadoc/org/apache/kafka/connect/connector/Task.html

[03/51] [partial] kafka-site git commit: Add 0.10.1 javadocs

2016-10-04 Thread jgus
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/2d621da3/0101/javadoc/org/apache/kafka/connect/data/package-tree.html -- diff --git a/0101/javadoc/org/apache/kafka/connect/data/package-tree.html

[13/51] [partial] kafka-site git commit: Add 0.10.1 javadocs

2016-10-04 Thread jgus
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/2d621da3/0101/javadoc/org/apache/kafka/common/serialization/Deserializer.html -- diff --git a/0101/javadoc/org/apache/kafka/common/serialization/Deserializer.html

[49/51] [partial] kafka-site git commit: Add 0.10.1 javadocs

2016-10-04 Thread jgus
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/2d621da3/0101/javadoc/constant-values.html -- diff --git a/0101/javadoc/constant-values.html b/0101/javadoc/constant-values.html new file mode 100644 index 000..afdd210

[41/51] [partial] kafka-site git commit: Add 0.10.1 javadocs

2016-10-04 Thread jgus
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/2d621da3/0101/javadoc/org/apache/kafka/clients/consumer/NoOffsetForPartitionException.html -- diff --git

[09/51] [partial] kafka-site git commit: Add 0.10.1 javadocs

2016-10-04 Thread jgus
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/2d621da3/0101/javadoc/org/apache/kafka/common/serialization/package-summary.html -- diff --git a/0101/javadoc/org/apache/kafka/common/serialization/package-summary.html

[21/51] [partial] kafka-site git commit: Add 0.10.1 javadocs

2016-10-04 Thread jgus
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/2d621da3/0101/javadoc/org/apache/kafka/common/errors/InvalidRequiredAcksException.html -- diff --git

[23/51] [partial] kafka-site git commit: Add 0.10.1 javadocs

2016-10-04 Thread jgus
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/2d621da3/0101/javadoc/org/apache/kafka/common/errors/InvalidCommitOffsetSizeException.html -- diff --git

  1   2   3   4   5   6   7   8   9   10   >