You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@kafka.apache.org by chamberlain1990 <gi...@git.apache.org> on 2015/12/04 07:47:29 UTC
[GitHub] kafka pull request: 0.9.0
GitHub user chamberlain1990 opened a pull request:
https://github.com/apache/kafka/pull/627
0.9.0
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/apache/kafka 0.9.0
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/kafka/pull/627.patch
To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:
This closes #627
----
commit 7710b367fd26a0c41565f35200748c23616b4477
Author: Gwen Shapira <cs...@gmail.com>
Date: 2015-11-07T03:46:30Z
Changing version to 0.9.0.0
commit 27d44afe664bff45d62f72335fdbb56671561512
Author: Jason Gustafson <ja...@confluent.io>
Date: 2015-11-08T19:38:50Z
KAFKA-2723: new consumer exception cleanup (0.9.0)
Author: Jason Gustafson <ja...@confluent.io>
Reviewers: Guozhang Wang
Closes #452 from hachikuji/KAFKA-2723
commit 32cd3e35f1ea8251a51860cc48a44fb2fbfd7c0e
Author: Jason Gustafson <ja...@confluent.io>
Date: 2015-11-08T20:36:42Z
HOTFIX: fix group coordinator edge cases around metadata storage callback (0.9.0)
Author: Jason Gustafson <ja...@confluent.io>
Reviewers: Guozhang Wang
Closes #453 from hachikuji/hotfix-group-coordinator-0.9
commit 1fd79f57b4a73308c59b797974086ca09af19b98
Author: Ewen Cheslack-Postava <me...@ewencp.org>
Date: 2015-11-09T04:41:35Z
KAFKA-2480: Handle retriable and non-retriable exceptions thrown by sink tasks.
Author: Ewen Cheslack-Postava <me...@ewencp.org>
Reviewers: Gwen Shapira
Closes #450 from ewencp/kafka-2480-unrecoverable-task-errors
(cherry picked from commit f4b87deefecf4902992a84d4a3fe3b99a94ff72b)
Signed-off-by: Gwen Shapira <cs...@gmail.com>
commit 48013222fd426685d2907a760290d2e7c7d25aea
Author: Geoff Anderson <ge...@confluent.io>
Date: 2015-11-09T04:52:16Z
KAFKA-2773; 0.9.0 branch)Fixed broken vagrant provision scripts for static zk/broker cluster
Author: Geoff Anderson <ge...@confluent.io>
Reviewers: Gwen Shapira
Closes #455 from granders/KAFKA-2773-0.9.0-vagrant-fix
commit 417e283d643d8865aa3e79dffa373c8cc853d78f
Author: Ewen Cheslack-Postava <me...@ewencp.org>
Date: 2015-11-09T06:11:03Z
KAFKA-2774: Rename Copycat to Kafka Connect
Author: Ewen Cheslack-Postava <me...@ewencp.org>
Reviewers: Gwen Shapira
Closes #456 from ewencp/kafka-2774-rename-copycat
(cherry picked from commit f2031d40639ef34c1591c22971394ef41c87652c)
Signed-off-by: Gwen Shapira <cs...@gmail.com>
commit 02fbdaa4475fd12a0fdccaa103bf27cbc1bfd077
Author: Rajini Sivaram <ra...@googlemail.com>
Date: 2015-11-09T15:23:47Z
KAFKA-2779; Close SSL socket channel on remote connection close
Close socket channel in finally block to avoid file descriptor leak when remote end closes the connection
Author: Rajini Sivaram <ra...@googlemail.com>
Reviewers: Ismael Juma <is...@juma.me.uk>, Jun Rao <ju...@gmail.com>
Closes #460 from rajinisivaram/KAFKA-2779
(cherry picked from commit efbebc6e843850b7ed9a1d015413c99f114a7d92)
Signed-off-by: Jun Rao <ju...@gmail.com>
commit fdefef9536acf8569607a980a25237ef4794f645
Author: Ewen Cheslack-Postava <me...@ewencp.org>
Date: 2015-11-09T17:10:20Z
KAFKA-2781; Only require signing artifacts when uploading archives.
Author: Ewen Cheslack-Postava <me...@ewencp.org>
Reviewers: Jun Rao <ju...@gmail.com>
Closes #461 from ewencp/kafka-2781-no-signing-for-install
(cherry picked from commit a24f9a23a6d8759538e91072e8d96d158d03bb63)
Signed-off-by: Jun Rao <ju...@gmail.com>
commit 7471394c5485a2114d35c6345d95e161a0ee6586
Author: Ewen Cheslack-Postava <me...@ewencp.org>
Date: 2015-11-09T18:19:27Z
KAFKA-2776: Fix lookup of schema conversion cache size in JsonConverter.
Author: Ewen Cheslack-Postava <me...@ewencp.org>
Reviewers: Gwen Shapira
Closes #458 from ewencp/kafka-2776-json-converter-cache-config-fix
(cherry picked from commit e9fc7b8c84908ae642339a2522a79f8bb5155728)
Signed-off-by: Gwen Shapira <cs...@gmail.com>
commit 3aa3e85d942b514cbe842a6b3c3fe214c0ecf401
Author: Jason Gustafson <ja...@confluent.io>
Date: 2015-11-09T18:26:17Z
HOTFIX: bug updating cache when loading group metadata
The bug causes only the first instance of group metadata in the topic to be written to the cache (because of the putIfNotExists in addGroup). Coordinator fail-over won't work properly unless the cache is loaded with the right metadata.
Author: Jason Gustafson <ja...@confluent.io>
Reviewers: Guozhang Wang
Closes #462 from hachikuji/hotfix-group-loading
(cherry picked from commit 2b04004de878823fe631af1f3f85108c0b38caec)
Signed-off-by: Guozhang Wang <wa...@gmail.com>
commit e627558a5e62d185c88650af845d7b74e9c290f8
Author: Ewen Cheslack-Postava <me...@ewencp.org>
Date: 2015-11-09T18:27:18Z
KAFKA-2775: Move exceptions into API package for Kafka Connect.
Author: Ewen Cheslack-Postava <me...@ewencp.org>
Reviewers: Gwen Shapira
Closes #457 from ewencp/kafka-2775-exceptions-in-api-package
(cherry picked from commit bc76e6704e8f14d59bb5d4fcf9bdf544c9e463bf)
Signed-off-by: Gwen Shapira <cs...@gmail.com>
commit 4069011ee4dc0f3500190bb93a3b79180cd34eda
Author: Ewen Cheslack-Postava <me...@ewencp.org>
Date: 2015-11-09T18:36:57Z
KAFKA-2778: Use zero loss settings by default for Connect source producers.
Author: Ewen Cheslack-Postava <me...@ewencp.org>
Reviewers: Gwen Shapira
Closes #459 from ewencp/kafka-2778-connect-source-zero-loss-settings
(cherry picked from commit 13ba57dcfc45e60de281cc55125e7446322308ba)
Signed-off-by: Gwen Shapira <cs...@gmail.com>
commit 0d2fdfa81566c6645dbc818fbd3722ddda90b87c
Author: Ewen Cheslack-Postava <me...@ewencp.org>
Date: 2015-11-09T18:39:34Z
KAFKA-2782: Fix KafkaBasedLogTest assertion and move it to the main test thread.
Author: Ewen Cheslack-Postava <me...@ewencp.org>
Reviewers: Gwen Shapira
Closes #463 from ewencp/kafka-2782-fix-kafka-based-log-test-assertion
(cherry picked from commit 75f2b8c8b42459a3ab2962f75f0e05fbbb9e8333)
Signed-off-by: Gwen Shapira <cs...@gmail.com>
commit f22ea2970a81e84effd633a3fe0daf6815816e82
Author: Geoff Anderson <ge...@confluent.io>
Date: 2015-11-09T18:45:51Z
KAFKA-2258: add failover to mirrormaker test
This PR adds failover to simple end to end mirror maker test
Marked as WIP for 2 reasons:
- We may want to add a couple more test cases where kafka is being used to store offsets
- There appears to be a test failure in the hard failover case
Author: Geoff Anderson <ge...@confluent.io>
Reviewers: Ewen Cheslack-Postava
Closes #427 from granders/KAFKA-2258-mirrormaker-test
(cherry picked from commit 7073fa7efea4acd6615f9dad4f649f6094be6332)
Signed-off-by: Gwen Shapira <cs...@gmail.com>
commit e176fcc7fb146bf9be2d8d8f2a4f5e02f4753731
Author: Grant Henke <gr...@gmail.com>
Date: 2015-11-09T19:02:46Z
KAFKA-2783; Drop outdated hadoop contrib modules
Author: Grant Henke <gr...@gmail.com>
Reviewers: Gwen Shapira
Closes #466 from granthenke/drop-contrib
(cherry picked from commit 69af573b35f04657e31f60e636aba19ffa0b2c84)
Signed-off-by: Gwen Shapira <cs...@gmail.com>
commit 0977c03ec31c009a7bb9ae1bb678afe060aa0347
Author: Jason Gustafson <ja...@confluent.io>
Date: 2015-11-09T19:17:18Z
KAFKA-2674: clarify onPartitionsRevoked behavior
Author: Jason Gustafson <ja...@confluent.io>
Reviewers: Guozhang Wang
Closes #467 from hachikuji/KAFKA-2674
(cherry picked from commit 359be3a682951fd469d690df8d9e7a5a89a9d03b)
Signed-off-by: Guozhang Wang <wa...@gmail.com>
commit 2e20898db8e34c15a8dc1146cc4a88d17da3f2a5
Author: Guozhang Wang <wa...@gmail.com>
Date: 2015-11-09T21:36:35Z
MINOR: remove old producer in config sections to align with APIs
Author: Guozhang Wang <wa...@gmail.com>
Reviewers: Gwen Shapira
Closes #468 from guozhangwang/WikiUpdate
(cherry picked from commit a87b978223a827c34db1341b2da3e17e571c4464)
Signed-off-by: Gwen Shapira <cs...@gmail.com>
commit a8b263c5fbf6edd11fe15d7a05c6efb9d9a63aee
Author: Ashish Singh <as...@cloudera.com>
Date: 2015-11-09T21:47:55Z
MINOR: Improve exception message that gets thrown for non-existent group
Author: Ashish Singh <as...@cloudera.com>
Reviewers: Guozhang Wang
Closes #471 from SinghAsDev/ExceptionMessage
(cherry picked from commit 3ebb4ee1b0803b755eaefc3286fe107868b7b085)
Signed-off-by: Guozhang Wang <wa...@gmail.com>
commit c258868879dc5bc0fe7929d48626c44b85d3f100
Author: Ewen Cheslack-Postava <me...@ewencp.org>
Date: 2015-11-09T23:08:34Z
KAFKA-2785; Include Kafka Connect jars in releaseTarGz.
Author: Ewen Cheslack-Postava <me...@ewencp.org>
Reviewers: Jun Rao <ju...@gmail.com>
Closes #473 from ewencp/kafka-2785-include-copycat-jars-in-release
(cherry picked from commit 79bdc17ab4b0157ceb5257e6c4ff646a3fa55f6d)
Signed-off-by: Jun Rao <ju...@gmail.com>
commit 2b97b6cc059d1d8f33d9ef943c758682015e776b
Author: Ewen Cheslack-Postava <me...@ewencp.org>
Date: 2015-11-10T00:29:30Z
KAFKA-2379: Add basic documentation for Kafka Connect.
Author: Ewen Cheslack-Postava <me...@ewencp.org>
Reviewers: Gwen Shapira
Closes #475 from ewencp/kafka-2379-connect-docs
(cherry picked from commit 83eaf3284fe8535bd06743a367a469d3d01946b1)
Signed-off-by: Gwen Shapira <cs...@gmail.com>
commit 2b382d6f92ed1d6f414529ce8d41089110ed560a
Author: Guozhang Wang <wa...@gmail.com>
Date: 2015-11-10T00:33:23Z
MINOR: remove Kafka Streams in 0.9.0
Author: Guozhang Wang <wa...@gmail.com>
Reviewers: Jun Rao
Closes #474 from guozhangwang/removeKStream
commit 98b625780c1f524c1f4fa55e099c88eb8a036fca
Author: Anna Povzner <an...@confluent.io>
Date: 2015-11-10T01:07:40Z
KAFKA-2769; Multi-consumer integration tests for consumer assignment incl. session timeouts and corresponding fixes
-- Refactored multi-consumer integration group assignment validation tests for round-robin assignment
-- Added multi-consumer integration tests for session timeout expiration:
1. When a consumer stops polling
2. When a consumer calls close()
-- Fixes to issues found with session timeout expiration tests woth help from Jason Gustafson: Try to avoid SendFailedException exception by cancelling the scheduled tasks and ensuring metadata update before sending group leave requests + send leave group request with retries.
Author: Anna Povzner <an...@confluent.io>
Reviewers: Jason Gustafson, Guozhang Wang
Closes #472 from apovzner/cpkafka-81
(cherry picked from commit c9264b4c8904bf330b70cd84b433a7a141ec9d0e)
Signed-off-by: Guozhang Wang <wa...@gmail.com>
commit e46959b624d2b1341fdc8b74a1571f78862fc140
Author: Jason Gustafson <ja...@confluent.io>
Date: 2015-11-10T02:38:22Z
KAFKA-2274: verifiable consumer and integration testing
Author: Jason Gustafson <ja...@confluent.io>
Reviewers: Guozhang Wang, Geoff Anderson
Closes #465 from hachikuji/KAFKA-2274
commit a621677bee2f3855cedb2b1b20301199e62260bb
Author: Ewen Cheslack-Postava <me...@ewencp.org>
Date: 2015-11-10T04:43:07Z
KAFKA-2786: Only respond to SinkTask onPartitionsRevoked after the WorkerSinkTask has finished starting up.
Author: Ewen Cheslack-Postava <me...@ewencp.org>
Reviewers: Gwen Shapira
Closes #476 from ewencp/kafka-2786-on-partitions-assigned-only-after-start
(cherry picked from commit 590a4616a1030b3175ba5a548b5f1e1b49c323c2)
Signed-off-by: Gwen Shapira <cs...@gmail.com>
commit 528d555fc39b93a52e1781bdba00db96d8554350
Author: Ewen Cheslack-Postava <me...@ewencp.org>
Date: 2015-11-10T18:17:13Z
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 <me...@ewencp.org>
Reviewers: Gwen Shapira
Closes #485 from ewencp/kafka-2797-disable-rat-when-git-missing
(cherry picked from commit fe11488a7787732b6cc2ba306f745ea1f318208c)
Signed-off-by: Gwen Shapira <cs...@gmail.com>
commit 69f2ad8e22e7183946e076a8cda122aa0964fd9c
Author: Ewen Cheslack-Postava <me...@ewencp.org>
Date: 2015-11-10T18:26:51Z
KAFKA-2792: Don't wait for a response to the leave group message when closing the new consumer.
Author: Ewen Cheslack-Postava <me...@ewencp.org>
Reviewers: Onur Karaman, Gwen Shapira
Closes #480 from ewencp/kafka-2792-fix-blocking-consumer-close
(cherry picked from commit ae5a5d7c08bb634576a414f6f2864c5b8a7e58a3)
Signed-off-by: Gwen Shapira <cs...@gmail.com>
commit dd8a870e4df11cad009498ebfb9b6eac78f1652f
Author: Ewen Cheslack-Postava <me...@ewencp.org>
Date: 2015-11-10T19:07:26Z
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 <me...@ewencp.org>
Reviewers: Gwen Shapira
Closes #486 from ewencp/kafka-2798-conflicting-herder-producer-consumer-configs
(cherry picked from commit 403d89edeaa7808f71c0e7318411c925895210f2)
Signed-off-by: Gwen Shapira <cs...@gmail.com>
commit c411ec808df33b9343e46ef7f812f1bd4b53d88d
Author: Geoff Anderson <ge...@confluent.io>
Date: 2015-11-10T19:54:18Z
MINOR: update system test readme
Author: Geoff Anderson <ge...@confluent.io>
Reviewers: Guozhang Wang
Closes #487 from granders/minor-update-test-readme
(cherry picked from commit 1d884d1f60aec9ec7ea334761bead4c60b13c7a9)
Signed-off-by: Guozhang Wang <wa...@gmail.com>
commit 7508ec219022c02aedb401bb01e5fa183b0db5c1
Author: Jason Gustafson <ja...@confluent.io>
Date: 2015-11-10T21:06:55Z
KAFKA-2795: fix potential NPE in GroupMetadataManager.addGroup
Author: Jason Gustafson <ja...@confluent.io>
Reviewers: Onur Karaman, Guozhang Wang
Closes #488 from hachikuji/KAFKA-2795
(cherry picked from commit c455e608c1f2c7be6ff0a721f49c1fe3ede0165f)
Signed-off-by: Guozhang Wang <wa...@gmail.com>
commit 501ac028273815f015cf97c8b48b4c34286cc1fb
Author: Parth Brahmbhatt <br...@gmail.com>
Date: 2015-11-10T22:27:55Z
KAFKA-2788; Allow specifying principals with comman in ACL CLI.
Author: Parth Brahmbhatt <br...@gmail.com>
Reviewers: Jun Rao <ju...@gmail.com>
Closes #489 from Parth-Brahmbhatt/KAFKA-2788
(cherry picked from commit 60c06734b345bbf292773e5b9206282ff3995968)
Signed-off-by: Jun Rao <ju...@gmail.com>
----
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at infrastructure@apache.org or file a JIRA ticket
with INFRA.
---
[GitHub] kafka pull request: 0.9.0
Posted by Humbedooh <gi...@git.apache.org>.
Github user Humbedooh closed the pull request at:
https://github.com/apache/kafka/pull/627
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at infrastructure@apache.org or file a JIRA ticket
with INFRA.
---