kafka git commit: KAFKA-2415; Fix transient failure in LogRecoveryTest

Repository: kafka Updated Branches: refs/heads/trunk a36befd81 - 68ad80f85 KAFKA-2415; Fix transient failure in LogRecoveryTest Author: Jiangjie Qin becket@gmail.com Author: Jiangjie Qin j...@jqin-ld1.linkedin.biz Reviewers: Ismael Juma, Gwen Shapira Closes #121 from

kafka git commit: Minor: Fixes to Selector's javadoc

Repository: kafka Updated Branches: refs/heads/trunk 63b820c59 - 47c99f387 Minor: Fixes to Selector's javadoc Author: Ismael Juma ism...@juma.me.uk Closes #126 from ijuma/minor-selector-javadoc-fixes and squashes the following commits: a26f529 [Ismael Juma] Minor fixes to Selector's

kafka git commit: KAFKA-2429: Add annotations to mark classes as stable/unstable

Repository: kafka Updated Branches: refs/heads/trunk 3902dc024 - 04b0d870b KAFKA-2429: Add annotations to mark classes as stable/unstable This also marks the consumer as unstable to show an example of using these annotations. Author: Ewen Cheslack-Postava m...@ewencp.org Reviewers: Gwen

kafka git commit: KAFKA-2436; log.retention.hours should be honored by LogManager

Repository: kafka Updated Branches: refs/heads/trunk 786867c2e - 503bd3664 KAFKA-2436; log.retention.hours should be honored by LogManager Author: Dong Lin lindon...@gmail.com Reviewers: Joel Koshy, Gwen Shapira Closes #142 from lindong28/KAFKA-2436 Project:

kafka git commit: KAFKA-2330: Vagrantfile sets global configs instead of per-provider override configs; patched by Ewen Cheslack-Postava, reviewed by Geoff Anderson and Gwen Shapira

Repository: kafka Updated Branches: refs/heads/trunk 0b04f9f34 - e4fc456ab KAFKA-2330: Vagrantfile sets global configs instead of per-provider override configs; patched by Ewen Cheslack-Postava, reviewed by Geoff Anderson and Gwen Shapira Project:

kafka git commit: KAFKA-2457; Fix how the argument is passed to `compileScala`

Repository: kafka Updated Branches: refs/heads/trunk 3285a9c89 - 6acd37720 KAFKA-2457; Fix how the argument is passed to `compileScala` Author: Ismael Juma ism...@juma.me.uk Reviewers: Gwen Shapira Closes #159 from ijuma/kafka-2457-fix Project:

kafka git commit: KAFKA-2439; Add MirrorMaker service class for system tests

Repository: kafka Updated Branches: refs/heads/trunk 6acd37720 - 1d2ae89c5 KAFKA-2439; Add MirrorMaker service class for system tests Added MirrorMaker service and a few corresponding sanity checks, as well as necessary config template files. A few additional updates to accomodate the

kafka git commit: KAFKA-2438; add maxParallelForks to build.gradle to speedup tests.

Repository: kafka Updated Branches: refs/heads/trunk 63b89658b - 786867c2e KAFKA-2438; add maxParallelForks to build.gradle to speedup tests. Author: Sriharsha Chintalapani har...@hortonworks.com Reviewers: Gwen Shapira Closes #143 from harshach/KAFKA-2438 Project:

kafka git commit: KAFKA-2100; Client Error doesn't preserve or display original server error code when it is an unknown code; Reviewed by Gwen, Guozhang and Ewen

Repository: kafka Updated Branches: refs/heads/trunk e43c9aff9 - b7bd2978d KAFKA-2100; Client Error doesn't preserve or display original server error code when it is an unknown code; Reviewed by Gwen, Guozhang and Ewen Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit:

kafka git commit: KAFKA-2386; increase timeouts for transient test failure in ConsumerCoordinatorResponseTests

Repository: kafka Updated Branches: refs/heads/trunk cd3dc7a5c - 3c0963084 KAFKA-2386; increase timeouts for transient test failure in ConsumerCoordinatorResponseTests There are two race conditions in the test case testGenerationIdIncrementsOnRebalance. First, a delay before the second join

kafka git commit: KAFKA-2407: Only create log directory when it will be used

Repository: kafka Updated Branches: refs/heads/trunk 9cefb2a0f - fc40016cf KAFKA-2407: Only create log directory when it will be used Author: Grant Henke granthe...@gmail.com Reviewers: Gwen Shapira Closes #115 from granthenke/log-fix and squashes the following commits: de36138 [Grant

kafka git commit: MINOR: Added to .gitignore Kafka server logs directory

Repository: kafka Updated Branches: refs/heads/trunk b152c0604 - cd3dc7a5c MINOR: Added to .gitignore Kafka server logs directory When running Kafka server from sources, logs directory gets created in root of repository, and kafka server logs end up there. Currently that directory is not

kafka git commit: KAFKA-2405; Don't kill the JVM on session establishment failure

Repository: kafka Updated Branches: refs/heads/trunk a56a79055 - 7a666f7aa KAFKA-2405; Don't kill the JVM on session establishment failure As noted in the JIRA https://issues.apache.org/jira/browse/KAFKA-2405 currently the KafkaHealthCheck causes the JVM to terminate in cases where session

[1/7] kafka git commit: KAFKA-2366; Initial patch for Copycat

Repository: kafka Updated Branches: refs/heads/trunk c8e62c981 - f6acfb089 http://git-wip-us.apache.org/repos/asf/kafka/blob/f6acfb08/copycat/runtime/src/test/java/org/apache/kafka/copycat/util/TestBackgroundThreadExceptionHandler.java

[4/7] kafka git commit: KAFKA-2366; Initial patch for Copycat

http://git-wip-us.apache.org/repos/asf/kafka/blob/f6acfb08/copycat/file/src/main/java/org/apache/kafka/copycat/file/FileStreamSinkConnector.java -- diff --git

[7/7] kafka git commit: KAFKA-2366; Initial patch for Copycat

KAFKA-2366; Initial patch for Copycat This is an initial patch implementing the basics of Copycat for KIP-26. The intent here is to start a review of the key pieces of the core API and get a reasonably functional, baseline, non-distributed implementation of Copycat in place to get things

[3/7] kafka git commit: KAFKA-2366; Initial patch for Copycat

http://git-wip-us.apache.org/repos/asf/kafka/blob/f6acfb08/copycat/runtime/src/main/java/org/apache/kafka/copycat/runtime/Herder.java -- diff --git a/copycat/runtime/src/main/java/org/apache/kafka/copycat/runtime/Herder.java

[6/7] kafka git commit: KAFKA-2366; Initial patch for Copycat

http://git-wip-us.apache.org/repos/asf/kafka/blob/f6acfb08/copycat/data/src/main/java/org/apache/kafka/copycat/data/DataRuntimeException.java -- diff --git

[2/7] kafka git commit: KAFKA-2366; Initial patch for Copycat

http://git-wip-us.apache.org/repos/asf/kafka/blob/f6acfb08/copycat/runtime/src/main/java/org/apache/kafka/copycat/storage/OffsetStorageWriter.java -- diff --git

[5/7] kafka git commit: KAFKA-2366; Initial patch for Copycat

http://git-wip-us.apache.org/repos/asf/kafka/blob/f6acfb08/copycat/data/src/main/java/org/apache/kafka/copycat/data/SchemaBuilder.java -- diff --git a/copycat/data/src/main/java/org/apache/kafka/copycat/data/SchemaBuilder.java

svn commit: r1696013 - /kafka/site/083/configuration.html

Author: gwenshap Date: Sat Aug 15 02:18:00 2015 New Revision: 1696013 URL: http://svn.apache.org/r1696013 Log: KAFKA-2433; Remove documentation on dead configuration item: replica.lag.max.messages; by Stepehn Powis Modified: kafka/site/083/configuration.html Modified: kafka/site/083

kafka git commit: KAFKA-2288; Follow-up to KAFKA-2249 - reduce logging and testing; Reviewd by Jun Rao

Repository: kafka Updated Branches: refs/heads/trunk 7a666f7aa - 9cefb2a0f KAFKA-2288; Follow-up to KAFKA-2249 - reduce logging and testing; Reviewd by Jun Rao Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/9cefb2a0

kafka git commit: KAFKA-2344; kafka-merge-pr improvements

Repository: kafka Updated Branches: refs/heads/trunk fd3b4cc41 - 18adec7ed KAFKA-2344; kafka-merge-pr improvements The first 4 commits are adapted from changes that have been done to the Spark version and the last one is the feature that gwenshap asked for. Author: Ismael Juma ism

kafka git commit: KAFKA-2355; Add an unit test to validate the deletion of a partition marked as deleted; patched by Edward Ribeiro, reviewed by Ashish Singh, Ismael Juma and Grant Henke

Repository: kafka Updated Branches: refs/heads/trunk 18adec7ed - 66c8647d8 KAFKA-2355; Add an unit test to validate the deletion of a partition marked as deleted; patched by Edward Ribeiro, reviewed by Ashish Singh, Ismael Juma and Grant Henke Project:

kafka git commit: KAFKA-2198: kafka-topics.sh exits with 0 status on failures; patched by Manikumar Reddy reviewed by Gwen Shapira

Repository: kafka Updated Branches: refs/heads/trunk bdbb9672f - a7e0ac365 KAFKA-2198: kafka-topics.sh exits with 0 status on failures; patched by Manikumar Reddy reviewed by Gwen Shapira Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit:

kafka git commit: KAFKA-2345; Attempt to delete a topic already marked for deletion throws ZkNodeExistsException; patched by Ashish Singh; reviewed by Sriharsha Chintalapani and Ismael Juma

Repository: kafka Updated Branches: refs/heads/trunk 15cba9f00 - a5b11886d KAFKA-2345; Attempt to delete a topic already marked for deletion throws ZkNodeExistsException; patched by Ashish Singh; reviewed by Sriharsha Chintalapani and Ismael Juma Project:

kafka git commit: KAFKA-2337; Verify that metric names will not collide when creating new topics; patched by Grant Henke; reviewed by Edward Ribeiro, Ashish Singh and Gwen Shapira

Repository: kafka Updated Branches: refs/heads/trunk 846362724 - 1d2bd6284 KAFKA-2337; Verify that metric names will not collide when creating new topics; patched by Grant Henke; reviewed by Edward Ribeiro, Ashish Singh and Gwen Shapira Project:

kafka git commit: KAFKA-2328; merge-kafka-pr.py script should not leave user in a detached branch

Repository: kafka Updated Branches: refs/heads/trunk 1d2bd6284 - 204089046 KAFKA-2328; merge-kafka-pr.py script should not leave user in a detached branch The right command to get the branch name is `git rev-parse --abbrev-ref HEAD` instead of `git rev-parse HEAD`. The latter gives the

kafka git commit: MINOR: update to correct clock skew

Repository: kafka Updated Branches: refs/heads/trunk 0da654761 -> e0ca8fdd7 MINOR: update to correct clock skew ewencp Updated the provisioning script to install ntp daemon. Author: Geoff Anderson Reviewers: Gwen Shapira Closes #383 from

kafka git commit: KAFKA-2645: Document potentially breaking changes in the release note…

Repository: kafka Updated Branches: refs/heads/trunk e6f9b9e47 -> fc4ef4791 KAFKA-2645: Document potentially breaking changes in the release note… …s for 0.9.0 Author: Grant Henke Reviewers: Gwen Shapira, Guozhang Wang Closes #337 from granthenke/docs Project:

kafka git commit: KAFKA-2452: Add new consumer option to mirror maker.

Repository: kafka Updated Branches: refs/heads/trunk 2e4aed707 -> 2fd645ac2 KAFKA-2452: Add new consumer option to mirror maker. Author: Jiangjie Qin Reviewers: Ben Stopford, Guozhang Wang Closes #266 from becketqin/KAFKA-2452 Project:

kafka git commit: KAFKA-2516: Rename o.a.k.client.tools to o.a.k.tools

Repository: kafka Updated Branches: refs/heads/trunk fc4ef4791 -> 2e4aed707 KAFKA-2516: Rename o.a.k.client.tools to o.a.k.tools Author: Grant Henke Reviewers: Gwen Shapira, Ewen Cheslack-Postava Closes #310 from granthenke/tools-packaging Project:

kafka git commit: KAFKA-2447: Add capability to KafkaLog4jAppender to be able to use SSL

Repository: kafka Updated Branches: refs/heads/trunk 2fd645ac2 -> d21cb66e7 KAFKA-2447: Add capability to KafkaLog4jAppender to be able to use SSL Author: Ashish Singh Reviewers: Gwen Shapira, Ismael Juma Closes #175 from SinghAsDev/KAFKA-2447 Project:

kafka git commit: MINOR: KAFKA-2371 follow-up, DistributedHerder should wakeup WorkerGroupMember after assignment to ensure work is started immediately

Repository: kafka Updated Branches: refs/heads/trunk 9855bb9c6 -> 8838fa801 MINOR: KAFKA-2371 follow-up, DistributedHerder should wakeup WorkerGroupMember after assignment to ensure work is started immediately Author: Ewen Cheslack-Postava Reviewers: Gwen Shapira Closes

kafka git commit: KAFKA-2671: Enable starting Kafka server with a Properties object

Repository: kafka Updated Branches: refs/heads/trunk aa56dfb9e -> 701c46b3a KAFKA-2671: Enable starting Kafka server with a Properties object Author: Ashish Singh Reviewers: Eno Thereska, Gwen Shapira Closes #330 from SinghAsDev/KAFKA-2671 Project:

kafka git commit: KAFKA-2626: Handle null keys and value validation properly in OffsetStorageWriter.

Repository: kafka Updated Branches: refs/heads/trunk 2e6177359 -> 6f2f1f984 KAFKA-2626: Handle null keys and value validation properly in OffsetStorageWriter. Author: Ewen Cheslack-Postava Reviewers: Gwen Shapira Closes #345 from

[3/3] kafka git commit: KAFKA-2371: Add distributed support for Copycat.

KAFKA-2371: Add distributed support for Copycat. This adds coordination between DistributedHerders using the generalized consumer support, allowing automatic balancing of connectors and tasks across workers. A few pieces that require interaction between workers (resolving config inconsistencies,

[1/3] kafka git commit: KAFKA-2371: Add distributed support for Copycat.

Repository: kafka Updated Branches: refs/heads/trunk 21443f214 -> 2e6177359 http://git-wip-us.apache.org/repos/asf/kafka/blob/2e617735/copycat/runtime/src/test/java/org/apache/kafka/copycat/runtime/distributed/DistributedHerderTest.java

[2/3] kafka git commit: KAFKA-2371: Add distributed support for Copycat.

http://git-wip-us.apache.org/repos/asf/kafka/blob/2e617735/copycat/runtime/src/main/java/org/apache/kafka/copycat/runtime/distributed/DistributedHerderConfig.java -- diff --git

kafka git commit: KAFKA-2797: Only run rat when in the .git repository since it require s the .gitignore to generate the list of files to ignore

Repository: kafka Updated Branches: refs/heads/trunk 590a4616a -> fe11488a7 KAFKA-2797: Only run rat when in the .git repository since it require s the .gitignore to generate the list of files to ignore Author: Ewen Cheslack-Postava Reviewers: Gwen Shapira Closes #485

kafka git commit: KAFKA-2797: Only run rat when in the .git repository since it require s the .gitignore to generate the list of files to ignore

Repository: kafka Updated Branches: refs/heads/0.9.0 a621677be -> 528d555fc KAFKA-2797: Only run rat when in the .git repository since it require s the .gitignore to generate the list of files to ignore Author: Ewen Cheslack-Postava Reviewers: Gwen Shapira Closes #485

kafka git commit: KAFKA-2792: Don't wait for a response to the leave group message when closing the new consumer.

Repository: kafka Updated Branches: refs/heads/0.9.0 528d555fc -> 69f2ad8e2 KAFKA-2792: Don't wait for a response to the leave group message when closing the new consumer. Author: Ewen Cheslack-Postava Reviewers: Onur Karaman, Gwen Shapira Closes #480 from

kafka git commit: KAFKA-2792: Don't wait for a response to the leave group message when closing the new consumer.

Repository: kafka Updated Branches: refs/heads/trunk fe11488a7 -> ae5a5d7c0 KAFKA-2792: Don't wait for a response to the leave group message when closing the new consumer. Author: Ewen Cheslack-Postava Reviewers: Onur Karaman, Gwen Shapira Closes #480 from

kafka git commit: KAFKA-2798: Use prefixedd configurations for Kafka Connect producer and consumer settings so they do not conflict with the distributed herder's settings.

Repository: kafka Updated Branches: refs/heads/trunk ae5a5d7c0 -> 403d89ede KAFKA-2798: Use prefixedd configurations for Kafka Connect producer and consumer settings so they do not conflict with the distributed herder's settings. Author: Ewen Cheslack-Postava Reviewers:

kafka git commit: KAFKA-2798: Use prefixedd configurations for Kafka Connect producer and consumer settings so they do not conflict with the distributed herder's settings.

Repository: kafka Updated Branches: refs/heads/0.9.0 69f2ad8e2 -> dd8a870e4 KAFKA-2798: Use prefixedd configurations for Kafka Connect producer and consumer settings so they do not conflict with the distributed herder's settings. Author: Ewen Cheslack-Postava Reviewers:

kafka git commit: KAFKA-2793: Use ByteArrayDeserializer instead of StringDeserializer for keys in ConsoleConsumer with new consumer.

Repository: kafka Updated Branches: refs/heads/trunk 60c06734b -> 64a1bfeb9 KAFKA-2793: Use ByteArrayDeserializer instead of StringDeserializer for keys in ConsoleConsumer with new consumer. Author: Ewen Cheslack-Postava Reviewers: Gwen Shapira Closes #482 from

kafka git commit: KAFKA-2793: Use ByteArrayDeserializer instead of StringDeserializer for keys in ConsoleConsumer with new consumer.

Repository: kafka Updated Branches: refs/heads/0.9.0 501ac0282 -> 75db96e42 KAFKA-2793: Use ByteArrayDeserializer instead of StringDeserializer for keys in ConsoleConsumer with new consumer. Author: Ewen Cheslack-Postava Reviewers: Gwen Shapira Closes #482 from

kafka git commit: MINOR: remove old producer in config sections to align with APIs

Repository: kafka Updated Branches: refs/heads/trunk 359be3a68 -> a87b97822 MINOR: remove old producer in config sections to align with APIs Author: Guozhang Wang Reviewers: Gwen Shapira Closes #468 from guozhangwang/WikiUpdate Project:

kafka git commit: KAFKA-2778: Use zero loss settings by default for Connect source producers.

Repository: kafka Updated Branches: refs/heads/trunk bc76e6704 -> 13ba57dcf KAFKA-2778: Use zero loss settings by default for Connect source producers. Author: Ewen Cheslack-Postava Reviewers: Gwen Shapira Closes #459 from

[2/2] kafka git commit: KAFKA-2783; Drop outdated hadoop contrib modules

KAFKA-2783; Drop outdated hadoop contrib modules Author: Grant Henke Reviewers: Gwen Shapira Closes #466 from granthenke/drop-contrib (cherry picked from commit 69af573b35f04657e31f60e636aba19ffa0b2c84) Signed-off-by: Gwen Shapira Project:

kafka git commit: KAFKA-2776: Fix lookup of schema conversion cache size in JsonConverter.

Repository: kafka Updated Branches: refs/heads/trunk a24f9a23a -> e9fc7b8c8 KAFKA-2776: Fix lookup of schema conversion cache size in JsonConverter. Author: Ewen Cheslack-Postava Reviewers: Gwen Shapira Closes #458 from ewencp/kafka-2776-json-converter-cache-config-fix

[1/2] kafka git commit: KAFKA-2783; Drop outdated hadoop contrib modules

Repository: kafka Updated Branches: refs/heads/0.9.0 f22ea2970 -> e176fcc7f http://git-wip-us.apache.org/repos/asf/kafka/blob/e176fcc7/contrib/hadoop-producer/README.md -- diff --git a/contrib/hadoop-producer/README.md

kafka git commit: KAFKA-2775: Move exceptions into API package for Kafka Connect.

Repository: kafka Updated Branches: refs/heads/trunk 2b04004de -> bc76e6704 KAFKA-2775: Move exceptions into API package for Kafka Connect. Author: Ewen Cheslack-Postava Reviewers: Gwen Shapira Closes #457 from ewencp/kafka-2775-exceptions-in-api-package Project:

kafka git commit: KAFKA-2782: Fix KafkaBasedLogTest assertion and move it to the main test thread.

Repository: kafka Updated Branches: refs/heads/0.9.0 4069011ee -> 0d2fdfa81 KAFKA-2782: Fix KafkaBasedLogTest assertion and move it to the main test thread. Author: Ewen Cheslack-Postava Reviewers: Gwen Shapira Closes #463 from

kafka git commit: KAFKA-2782: Fix KafkaBasedLogTest assertion and move it to the main test thread.

Repository: kafka Updated Branches: refs/heads/trunk 13ba57dcf -> 75f2b8c8b KAFKA-2782: Fix KafkaBasedLogTest assertion and move it to the main test thread. Author: Ewen Cheslack-Postava Reviewers: Gwen Shapira Closes #463 from

[10/26] kafka git commit: KAFKA-2774: Rename Copycat to Kafka Connect

http://git-wip-us.apache.org/repos/asf/kafka/blob/f2031d40/copycat/json/src/main/java/org/apache/kafka/copycat/json/JsonConverter.java -- diff --git a/copycat/json/src/main/java/org/apache/kafka/copycat/json/JsonConverter.java

kafka git commit: KAFKA-2826: Make Kafka Connect ducktape services easier to extend.

Repository: kafka Updated Branches: refs/heads/trunk 2802bd081 -> 969d0cb0a KAFKA-2826: Make Kafka Connect ducktape services easier to extend. Author: Ewen Cheslack-Postava Reviewers: Gwen Shapira Closes #522 from ewencp/kafka-2826-extensible-connect-services Project:

kafka git commit: MINOR: Increase timeouts for Kafka Connect system test service to make tests more reliable on wimpy nodes.

Repository: kafka Updated Branches: refs/heads/0.9.0 c5965820a -> d04a918a2 MINOR: Increase timeouts for Kafka Connect system test service to make tests more reliable on wimpy nodes. Author: Ewen Cheslack-Postava Reviewers: Gwen Shapira Closes #514 from

kafka git commit: MINOR: Tuned timeout parameter to reduce chance of transient failure

Repository: kafka Updated Branches: refs/heads/0.9.0 c4e069ae5 -> e8f92d620 MINOR: Tuned timeout parameter to reduce chance of transient failure Increased timeout in downstream consumer doing validation step. This addresses a transient failure case in mirror maker tests with mirror maker

kafka git commit: Minor: Missing License

Repository: kafka Updated Branches: refs/heads/trunk da9733091 -> 4511aeebc Minor: Missing License Author: Sriharsha Chintalapani Reviewers: Gwen Shapira Closes #524 from harshach/missing-license Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit:

kafka git commit: Minor: Missing License

Repository: kafka Updated Branches: refs/heads/0.9.0 cb0de177c -> 3e133c4ee Minor: Missing License Author: Sriharsha Chintalapani Reviewers: Gwen Shapira Closes #524 from harshach/missing-license (cherry picked from commit 4511aeebc3e37a3d9e2ebeabbd6bbfd16d681719)

kafka git commit: KAFKA-2807: Move ThroughputThrottler back to tools jar to fix upgrade tests.

Repository: kafka Updated Branches: refs/heads/trunk a8ccdc615 -> c6b8de4e6 KAFKA-2807: Move ThroughputThrottler back to tools jar to fix upgrade tests. Author: Ewen Cheslack-Postava Reviewers: Gwen Shapira Closes #499 from ewencp/kafka-2807-relocate-throughput-throttler

kafka git commit: KAFKA-2690: Hide passwords while logging the config.

Repository: kafka Updated Branches: refs/heads/trunk 370ce2b4b -> ab5ac264a KAFKA-2690: Hide passwords while logging the config. Added PASSWORD_STRING in ConfigDef that returns "[hidden]" when method toString is invoked. Author: Jakub Nowak Reviewers: Ismael

kafka git commit: KAFKA-2690: Hide passwords while logging the config.

Repository: kafka Updated Branches: refs/heads/0.9.0 98124930f -> c5965820a KAFKA-2690: Hide passwords while logging the config. Added PASSWORD_STRING in ConfigDef that returns "[hidden]" when method toString is invoked. Author: Jakub Nowak Reviewers: Ismael

kafka git commit: KAFKA-2790: doc improvements

Repository: kafka Updated Branches: refs/heads/0.9.0 0ea17e959 -> 1828b8e52 KAFKA-2790: doc improvements Author: Gwen Shapira <csh...@gmail.com> Reviewers: Jun Rao, Guozhang Wang Closes #491 from gwenshap/KAFKA-2790 (cherry picked from commit a8ccdc6154a1e10982cb80df82e8661

kafka git commit: KAFKA-2786: Only respond to SinkTask onPartitionsRevoked after the WorkerSinkTask has finished starting up.

Repository: kafka Updated Branches: refs/heads/trunk bce664b42 -> 590a4616a KAFKA-2786: Only respond to SinkTask onPartitionsRevoked after the WorkerSinkTask has finished starting up. Author: Ewen Cheslack-Postava Reviewers: Gwen Shapira Closes #476 from

[09/26] kafka git commit: KAFKA-2774: Rename Copycat to Kafka Connect

http://git-wip-us.apache.org/repos/asf/kafka/blob/f2031d40/copycat/runtime/src/main/java/org/apache/kafka/copycat/errors/AlreadyExistsException.java -- diff --git

[14/26] kafka git commit: KAFKA-2774: Rename Copycat to Kafka Connect

http://git-wip-us.apache.org/repos/asf/kafka/blob/417e283d/connect/runtime/src/test/java/org/apache/kafka/connect/storage/KafkaOffsetBackingStoreTest.java -- diff --git

[22/26] kafka git commit: KAFKA-2774: Rename Copycat to Kafka Connect

http://git-wip-us.apache.org/repos/asf/kafka/blob/f2031d40/connect/json/src/main/java/org/apache/kafka/connect/json/JsonConverter.java -- diff --git a/connect/json/src/main/java/org/apache/kafka/connect/json/JsonConverter.java

[18/26] kafka git commit: KAFKA-2774: Rename Copycat to Kafka Connect

http://git-wip-us.apache.org/repos/asf/kafka/blob/417e283d/connect/runtime/src/main/java/org/apache/kafka/connect/runtime/rest/entities/CreateConnectorRequest.java -- diff --git

[11/26] kafka git commit: KAFKA-2774: Rename Copycat to Kafka Connect

http://git-wip-us.apache.org/repos/asf/kafka/blob/417e283d/copycat/api/src/test/java/org/apache/kafka/copycat/data/SchemaProjectorTest.java -- diff --git

[19/26] kafka git commit: KAFKA-2774: Rename Copycat to Kafka Connect

http://git-wip-us.apache.org/repos/asf/kafka/blob/f2031d40/connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/DistributedHerder.java -- diff --git

[17/26] kafka git commit: KAFKA-2774: Rename Copycat to Kafka Connect

http://git-wip-us.apache.org/repos/asf/kafka/blob/417e283d/connect/runtime/src/main/java/org/apache/kafka/connect/storage/KafkaOffsetBackingStore.java -- diff --git

[12/26] kafka git commit: KAFKA-2774: Rename Copycat to Kafka Connect

http://git-wip-us.apache.org/repos/asf/kafka/blob/417e283d/copycat/api/src/main/java/org/apache/kafka/copycat/sink/SinkTask.java -- diff --git a/copycat/api/src/main/java/org/apache/kafka/copycat/sink/SinkTask.java

[14/26] kafka git commit: KAFKA-2774: Rename Copycat to Kafka Connect

http://git-wip-us.apache.org/repos/asf/kafka/blob/f2031d40/connect/runtime/src/test/java/org/apache/kafka/connect/storage/KafkaOffsetBackingStoreTest.java -- diff --git

[16/26] kafka git commit: KAFKA-2774: Rename Copycat to Kafka Connect

http://git-wip-us.apache.org/repos/asf/kafka/blob/f2031d40/connect/runtime/src/test/java/org/apache/kafka/connect/runtime/WorkerSinkTaskThreadedTest.java -- diff --git

[19/26] kafka git commit: KAFKA-2774: Rename Copycat to Kafka Connect

http://git-wip-us.apache.org/repos/asf/kafka/blob/417e283d/connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/DistributedHerder.java -- diff --git

[21/26] kafka git commit: KAFKA-2774: Rename Copycat to Kafka Connect

http://git-wip-us.apache.org/repos/asf/kafka/blob/417e283d/connect/runtime/src/main/java/org/apache/kafka/connect/errors/AlreadyExistsException.java -- diff --git

[24/26] kafka git commit: KAFKA-2774: Rename Copycat to Kafka Connect

http://git-wip-us.apache.org/repos/asf/kafka/blob/417e283d/connect/api/src/main/java/org/apache/kafka/connect/source/SourceRecord.java -- diff --git a/connect/api/src/main/java/org/apache/kafka/connect/source/SourceRecord.java

[08/26] kafka git commit: KAFKA-2774: Rename Copycat to Kafka Connect

http://git-wip-us.apache.org/repos/asf/kafka/blob/417e283d/copycat/runtime/src/main/java/org/apache/kafka/copycat/runtime/WorkerSourceTask.java -- diff --git

[02/26] kafka git commit: KAFKA-2774: Rename Copycat to Kafka Connect

http://git-wip-us.apache.org/repos/asf/kafka/blob/417e283d/copycat/runtime/src/test/java/org/apache/kafka/copycat/storage/KafkaOffsetBackingStoreTest.java -- diff --git

[06/26] kafka git commit: KAFKA-2774: Rename Copycat to Kafka Connect

http://git-wip-us.apache.org/repos/asf/kafka/blob/f2031d40/copycat/runtime/src/main/java/org/apache/kafka/copycat/runtime/rest/entities/CreateConnectorRequest.java -- diff --git

[03/26] kafka git commit: KAFKA-2774: Rename Copycat to Kafka Connect

http://git-wip-us.apache.org/repos/asf/kafka/blob/f2031d40/copycat/runtime/src/test/java/org/apache/kafka/copycat/runtime/distributed/WorkerCoordinatorTest.java -- diff --git

[25/26] kafka git commit: KAFKA-2774: Rename Copycat to Kafka Connect

http://git-wip-us.apache.org/repos/asf/kafka/blob/417e283d/connect/api/src/main/java/org/apache/kafka/connect/data/Date.java -- diff --git a/connect/api/src/main/java/org/apache/kafka/connect/data/Date.java

[06/26] kafka git commit: KAFKA-2774: Rename Copycat to Kafka Connect

http://git-wip-us.apache.org/repos/asf/kafka/blob/417e283d/copycat/runtime/src/main/java/org/apache/kafka/copycat/runtime/rest/entities/CreateConnectorRequest.java -- diff --git

[01/26] kafka git commit: KAFKA-2774: Rename Copycat to Kafka Connect

Repository: kafka Updated Branches: refs/heads/0.9.0 48013222f -> 417e283d6 http://git-wip-us.apache.org/repos/asf/kafka/blob/417e283d/tests/kafkatest/tests/connect_distributed_test.py -- diff --git

[26/26] kafka git commit: KAFKA-2774: Rename Copycat to Kafka Connect

KAFKA-2774: Rename Copycat to Kafka Connect Author: Ewen Cheslack-Postava Reviewers: Gwen Shapira Closes #456 from ewencp/kafka-2774-rename-copycat (cherry picked from commit f2031d40639ef34c1591c22971394ef41c87652c) Signed-off-by: Gwen Shapira Project:

[21/26] kafka git commit: KAFKA-2774: Rename Copycat to Kafka Connect

http://git-wip-us.apache.org/repos/asf/kafka/blob/f2031d40/connect/runtime/src/main/java/org/apache/kafka/connect/errors/AlreadyExistsException.java -- diff --git

[07/26] kafka git commit: KAFKA-2774: Rename Copycat to Kafka Connect

http://git-wip-us.apache.org/repos/asf/kafka/blob/417e283d/copycat/runtime/src/main/java/org/apache/kafka/copycat/runtime/distributed/DistributedHerder.java -- diff --git

[20/26] kafka git commit: KAFKA-2774: Rename Copycat to Kafka Connect

http://git-wip-us.apache.org/repos/asf/kafka/blob/f2031d40/connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerSourceTask.java -- diff --git

[13/26] kafka git commit: KAFKA-2774: Rename Copycat to Kafka Connect

http://git-wip-us.apache.org/repos/asf/kafka/blob/417e283d/copycat/api/src/main/java/org/apache/kafka/copycat/data/CopycatSchema.java -- diff --git a/copycat/api/src/main/java/org/apache/kafka/copycat/data/CopycatSchema.java

[25/26] kafka git commit: KAFKA-2774: Rename Copycat to Kafka Connect

http://git-wip-us.apache.org/repos/asf/kafka/blob/f2031d40/connect/api/src/main/java/org/apache/kafka/connect/data/Date.java -- diff --git a/connect/api/src/main/java/org/apache/kafka/connect/data/Date.java

[18/26] kafka git commit: KAFKA-2774: Rename Copycat to Kafka Connect

http://git-wip-us.apache.org/repos/asf/kafka/blob/f2031d40/connect/runtime/src/main/java/org/apache/kafka/connect/runtime/rest/entities/CreateConnectorRequest.java -- diff --git

[16/26] kafka git commit: KAFKA-2774: Rename Copycat to Kafka Connect

http://git-wip-us.apache.org/repos/asf/kafka/blob/417e283d/connect/runtime/src/test/java/org/apache/kafka/connect/runtime/WorkerSinkTaskThreadedTest.java -- diff --git

[23/26] kafka git commit: KAFKA-2774: Rename Copycat to Kafka Connect

http://git-wip-us.apache.org/repos/asf/kafka/blob/417e283d/connect/api/src/test/java/org/apache/kafka/connect/data/SchemaProjectorTest.java -- diff --git

[09/26] kafka git commit: KAFKA-2774: Rename Copycat to Kafka Connect

http://git-wip-us.apache.org/repos/asf/kafka/blob/417e283d/copycat/runtime/src/main/java/org/apache/kafka/copycat/errors/AlreadyExistsException.java -- diff --git

[04/26] kafka git commit: KAFKA-2774: Rename Copycat to Kafka Connect

http://git-wip-us.apache.org/repos/asf/kafka/blob/f2031d40/copycat/runtime/src/test/java/org/apache/kafka/copycat/runtime/WorkerSinkTaskThreadedTest.java -- diff --git

[13/26] kafka git commit: KAFKA-2774: Rename Copycat to Kafka Connect

http://git-wip-us.apache.org/repos/asf/kafka/blob/f2031d40/copycat/api/src/main/java/org/apache/kafka/copycat/data/CopycatSchema.java -- diff --git a/copycat/api/src/main/java/org/apache/kafka/copycat/data/CopycatSchema.java

[05/26] kafka git commit: KAFKA-2774: Rename Copycat to Kafka Connect

http://git-wip-us.apache.org/repos/asf/kafka/blob/f2031d40/copycat/runtime/src/main/java/org/apache/kafka/copycat/storage/KafkaOffsetBackingStore.java -- diff --git

[08/26] kafka git commit: KAFKA-2774: Rename Copycat to Kafka Connect

http://git-wip-us.apache.org/repos/asf/kafka/blob/f2031d40/copycat/runtime/src/main/java/org/apache/kafka/copycat/runtime/WorkerSourceTask.java -- diff --git

  1   2   3   4   5   6   7   >