[GitHub] kafka pull request: add support for reassignment partition to spec...

GitHub user yonghuiyang opened a pull request: https://github.com/apache/kafka/pull/484 add support for reassignment partition to specified logdir add support for reassignment partition to specified logdir You can merge this pull request into a Git repository by running: $ gi

[jira] [Created] (KAFKA-2795) potential NPE in GroupMetadataManager

Onur Karaman created KAFKA-2795: --- Summary: potential NPE in GroupMetadataManager Key: KAFKA-2795 URL: https://issues.apache.org/jira/browse/KAFKA-2795 Project: Kafka Issue Type: Bug

[jira] [Created] (KAFKA-2796) add support for reassignment partition to specified logdir

Yonghui Yang created KAFKA-2796: --- Summary: add support for reassignment partition to specified logdir Key: KAFKA-2796 URL: https://issues.apache.org/jira/browse/KAFKA-2796 Project: Kafka Issue

[jira] [Updated] (KAFKA-2796) add support for reassignment partition to specified logdir

[ https://issues.apache.org/jira/browse/KAFKA-2796?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yonghui Yang updated KAFKA-2796: Affects Version/s: (was: 0.9.0.0) Description: Currently when creating a log, the dire

[jira] [Updated] (KAFKA-2796) add support for reassignment partition to specified logdir

[ https://issues.apache.org/jira/browse/KAFKA-2796?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yonghui Yang updated KAFKA-2796: Reviewer: Guozhang Wang > add support for reassignment partition to specified logdir > -

[jira] [Commented] (KAFKA-2690) Protect passwords from logging

[ https://issues.apache.org/jira/browse/KAFKA-2690?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14998365#comment-14998365 ] Ismael Juma commented on KAFKA-2690: PR link: https://github.com/apache/kafka/pull/371

[jira] [Commented] (KAFKA-2642) Run replication tests in ducktape with SSL for clients

[ https://issues.apache.org/jira/browse/KAFKA-2642?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14998374#comment-14998374 ] Ismael Juma commented on KAFKA-2642: Is this done then? > Run replication tests in du

[jira] [Commented] (KAFKA-2643) Run mirror maker tests in ducktape with SSL

[ https://issues.apache.org/jira/browse/KAFKA-2643?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14998375#comment-14998375 ] Ismael Juma commented on KAFKA-2643: Any update on this? > Run mirror maker tests in

Re: [VOTE] 0.9.0.0 Candiate 1

-1 (non-binding) I'm getting an error with gradle when using the source artifact because it seems to be expecting a git repository here: line 68 of build.gradle: def repo = Grgit.open(project.file('.')) and I get this message: FAILURE: Build failed with an exception. *

[jira] [Commented] (KAFKA-2643) Run mirror maker tests in ducktape with SSL

[ https://issues.apache.org/jira/browse/KAFKA-2643?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14998473#comment-14998473 ] Rajini Sivaram commented on KAFKA-2643: --- Will submit a PR next week. > Run mirror m

[jira] [Commented] (KAFKA-2642) Run replication tests in ducktape with SSL for clients

[ https://issues.apache.org/jira/browse/KAFKA-2642?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14998470#comment-14998470 ] Rajini Sivaram commented on KAFKA-2642: --- No, I didn't commit the changes under KAFKA

[jira] [Created] (KAFKA-2797) Release artifact expects a git repository for the release audit tool (RAT)

Flavio Junqueira created KAFKA-2797: --- Summary: Release artifact expects a git repository for the release audit tool (RAT) Key: KAFKA-2797 URL: https://issues.apache.org/jira/browse/KAFKA-2797 Projec

Dependency Updates

With a new major release comes the opportunity to update dependencies; potentially including bug fixes, performance improvements, and useful features. Below is some analysis of the current state of Kafka dependencies and the available updates with change logs: Note: this shows [Current -> Newest],

[jira] [Updated] (KAFKA-2788) allow comma when specifying principals in AclCommand

[ https://issues.apache.org/jira/browse/KAFKA-2788?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-2788: --- Priority: Blocker (was: Major) > allow comma when specifying principals in AclCommand > -

[jira] [Commented] (KAFKA-2788) allow comma when specifying principals in AclCommand

[ https://issues.apache.org/jira/browse/KAFKA-2788?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14998899#comment-14998899 ] Ben Stopford commented on KAFKA-2788: - I'll pick this one up if you haven't done it ye

Re: [DISCUSS] KIP-36 - Rack aware replica assignment

I am busy with some time pressing issues for the last few days. I will think about how the incomplete rack information will affect the balance and update the KIP by early next week. Thanks, Allen On Tue, Nov 3, 2015 at 9:03 AM, Neha Narkhede wrote: > Few suggestions on improving the KIP > > *I

[jira] [Commented] (KAFKA-2788) allow comma when specifying principals in AclCommand

[ https://issues.apache.org/jira/browse/KAFKA-2788?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14998905#comment-14998905 ] Parth Brahmbhatt commented on KAFKA-2788: - I have started working on it, will send

[jira] [Commented] (KAFKA-2788) allow comma when specifying principals in AclCommand

[ https://issues.apache.org/jira/browse/KAFKA-2788?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14998910#comment-14998910 ] Ben Stopford commented on KAFKA-2788: - OK Parth. Thanks. Ping me if you want a review.

Re: Dependency Updates

Hi, Grant, Thanks for the email. Yes, we should try to keep up with the latest stable version of the dependencies. We want to be a bit careful with api compatibilities for dependencies used in the clients. Incompatible changes make the upgrade of the clients painful. For example, metrics-core wasn

[GitHub] kafka pull request: KAFKA-2797: Only run rat when in the .git repo...

GitHub user ewencp opened a pull request: https://github.com/apache/kafka/pull/485 KAFKA-2797: Only run rat when in the .git repository since it require s the .gitignore to generate the list of files to ignore You can merge this pull request into a Git repository by running:

[jira] [Commented] (KAFKA-2797) Release artifact expects a git repository for the release audit tool (RAT)

[ https://issues.apache.org/jira/browse/KAFKA-2797?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14998996#comment-14998996 ] ASF GitHub Bot commented on KAFKA-2797: --- GitHub user ewencp opened a pull request:

[jira] [Updated] (KAFKA-2797) Release artifact expects a git repository for the release audit tool (RAT)

[ https://issues.apache.org/jira/browse/KAFKA-2797?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-2797: - Reviewer: Gwen Shapira Status: Patch Available (was: Open) > Release artifa

[jira] [Assigned] (KAFKA-2797) Release artifact expects a git repository for the release audit tool (RAT)

[ https://issues.apache.org/jira/browse/KAFKA-2797?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava reassigned KAFKA-2797: Assignee: Ewen Cheslack-Postava > Release artifact expects a git repository

[GitHub] kafka pull request: KAFKA-2797: Only run rat when in the .git repo...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/485 --- 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 enabl

[jira] [Updated] (KAFKA-2797) Release artifact expects a git repository for the release audit tool (RAT)

[ https://issues.apache.org/jira/browse/KAFKA-2797?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira updated KAFKA-2797: Resolution: Fixed Status: Resolved (was: Patch Available) Issue resolved by pull request 48

[jira] [Commented] (KAFKA-2797) Release artifact expects a git repository for the release audit tool (RAT)

[ https://issues.apache.org/jira/browse/KAFKA-2797?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14999055#comment-14999055 ] ASF GitHub Bot commented on KAFKA-2797: --- Github user asfgit closed the pull request

[jira] [Created] (KAFKA-2798) Kafka Connect distributed configs can conflict with producer/consumer configs, making it impossible to control them independently

Ewen Cheslack-Postava created KAFKA-2798: Summary: Kafka Connect distributed configs can conflict with producer/consumer configs, making it impossible to control them independently Key: KAFKA-2798 URL: htt

[GitHub] kafka pull request: KAFKA-2792: Don't wait for a response to the l...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/480 --- 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 enabl

[jira] [Commented] (KAFKA-2792) KafkaConsumer.close() can block unnecessarily due to leave group waiting for a reply

[ https://issues.apache.org/jira/browse/KAFKA-2792?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14999069#comment-14999069 ] ASF GitHub Bot commented on KAFKA-2792: --- Github user asfgit closed the pull request

[jira] [Resolved] (KAFKA-2792) KafkaConsumer.close() can block unnecessarily due to leave group waiting for a reply

[ https://issues.apache.org/jira/browse/KAFKA-2792?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira resolved KAFKA-2792. - Resolution: Fixed Issue resolved by pull request 480 [https://github.com/apache/kafka/pull/480] >

[jira] [Created] (KAFKA-2799) WakupException thrown in the followup poll() could lead to data loss

Guozhang Wang created KAFKA-2799: Summary: WakupException thrown in the followup poll() could lead to data loss Key: KAFKA-2799 URL: https://issues.apache.org/jira/browse/KAFKA-2799 Project: Kafka

Re: [VOTE] 0.9.0.0 Candiate 1

Jun, not sure if this is just because of the RC vs being published on the site, but the links in the release notes aren't pointing to issues.apache.org. They're relative URLs instead of absolute. -Ewen On Tue, Nov 10, 2015 at 3:38 AM, Flavio Junqueira wrote: > -1 (non-binding) > > I'm getting a

Build failed in Jenkins: kafka-trunk-jdk7 #794

See Changes: [cshapi] KAFKA-2797: Only run rat when in the .git repository since it require s [cshapi] KAFKA-2792: Don't wait for a response to the leave group message when -- [...truncated 96 l

[GitHub] kafka pull request: KAFKA-2798: Use prefixedd configurations for K...

GitHub user ewencp opened a pull request: https://github.com/apache/kafka/pull/486 KAFKA-2798: Use prefixedd configurations for Kafka Connect producer and consumer settings so they do not conflict with the distributed herder's settings. You can merge this pull request into a Git

[jira] [Commented] (KAFKA-2798) Kafka Connect distributed configs can conflict with producer/consumer configs, making it impossible to control them independently

[ https://issues.apache.org/jira/browse/KAFKA-2798?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14999114#comment-14999114 ] ASF GitHub Bot commented on KAFKA-2798: --- GitHub user ewencp opened a pull request:

[jira] [Updated] (KAFKA-2419) Allow certain Sensors to be garbage collected after inactivity

[ https://issues.apache.org/jira/browse/KAFKA-2419?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira updated KAFKA-2419: Issue Type: Improvement (was: New Feature) > Allow certain Sensors to be garbage collected after in

[GitHub] kafka pull request: MINOR: update system test readme

GitHub user granders opened a pull request: https://github.com/apache/kafka/pull/487 MINOR: update system test readme You can merge this pull request into a Git repository by running: $ git pull https://github.com/confluentinc/kafka minor-update-test-readme Alternatively you

[jira] [Updated] (KAFKA-2106) Partition balance tool between borkers

[ https://issues.apache.org/jira/browse/KAFKA-2106?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira updated KAFKA-2106: Fix Version/s: (was: 0.9.0.0) > Partition balance tool between borkers > ---

[jira] [Updated] (KAFKA-1810) Add IP Filtering / Whitelists-Blacklists

[ https://issues.apache.org/jira/browse/KAFKA-1810?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira updated KAFKA-1810: Fix Version/s: (was: 0.9.0.0) > Add IP Filtering / Whitelists-Blacklists >

[GitHub] kafka pull request: KAFKA-2798: Use prefixedd configurations for K...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/486 --- 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 enabl

[jira] [Resolved] (KAFKA-2798) Kafka Connect distributed configs can conflict with producer/consumer configs, making it impossible to control them independently

[ https://issues.apache.org/jira/browse/KAFKA-2798?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira resolved KAFKA-2798. - Resolution: Fixed Fix Version/s: 0.9.0.0 Issue resolved by pull request 486 [https://github

[jira] [Commented] (KAFKA-2798) Kafka Connect distributed configs can conflict with producer/consumer configs, making it impossible to control them independently

[ https://issues.apache.org/jira/browse/KAFKA-2798?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14999135#comment-14999135 ] ASF GitHub Bot commented on KAFKA-2798: --- Github user asfgit closed the pull request

Build failed in Jenkins: kafka-trunk-jdk8 #125

See Changes: [cshapi] KAFKA-2797: Only run rat when in the .git repository since it require s [cshapi] KAFKA-2792: Don't wait for a response to the leave group message when [cshapi] KAFKA-2798: Use prefixedd configurations for Kafka C

Build failed in Jenkins: kafka-trunk-jdk7 #795

See Changes: [cshapi] KAFKA-2798: Use prefixedd configurations for Kafka Connect producer and -- [...truncated 316 lines...] :kafka-trunk-jdk7:clients:classes UP-TO-DATE :kafka-trunk-jdk7:clients

Build failed in Jenkins: kafka-trunk-jdk7 #796

See -- [...truncated 133 lines...] :36: value DEFAULT_TIMESTAMP in object OffsetCommitRequ

[jira] [Commented] (KAFKA-2795) potential NPE in GroupMetadataManager

[ https://issues.apache.org/jira/browse/KAFKA-2795?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14999181#comment-14999181 ] Jason Gustafson commented on KAFKA-2795: Nice catch. Seems like we need to use the

[jira] [Assigned] (KAFKA-2795) potential NPE in GroupMetadataManager

[ https://issues.apache.org/jira/browse/KAFKA-2795?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson reassigned KAFKA-2795: -- Assignee: Jason Gustafson (was: Guozhang Wang) > potential NPE in GroupMetadataManager

Re: [kafka-clients] Re: [VOTE] 0.9.0.0 Candiate 1

Ewen, Thanks for reporting that. Will fix that in RC2. Jun On Tue, Nov 10, 2015 at 10:41 AM, Ewen Cheslack-Postava wrote: > Jun, not sure if this is just because of the RC vs being published on the > site, but the links in the release notes aren't pointing to > issues.apache.org. They're relat

[jira] [Commented] (KAFKA-2795) potential NPE in GroupMetadataManager

[ https://issues.apache.org/jira/browse/KAFKA-2795?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14999194#comment-14999194 ] Onur Karaman commented on KAFKA-2795: - definitely seems better than before. > potenti

[GitHub] kafka pull request: MINOR: update system test readme

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/487 --- 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 enabl

[jira] [Commented] (KAFKA-2792) KafkaConsumer.close() can block unnecessarily due to leave group waiting for a reply

[ https://issues.apache.org/jira/browse/KAFKA-2792?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14999211#comment-14999211 ] Guozhang Wang commented on KAFKA-2792: -- [~ewencp] [~onurkaraman] If we fire-and-forge

[jira] [Commented] (KAFKA-2795) potential NPE in GroupMetadataManager

[ https://issues.apache.org/jira/browse/KAFKA-2795?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14999221#comment-14999221 ] Guozhang Wang commented on KAFKA-2795: -- +1. Originally it was written in the above c

Re: [kafka-clients] Re: [VOTE] 0.9.0.0 Candiate 1

There's also a concurrency bug in the GroupMetadataManager that we'd probably want fixed before the 0.9.0.0 release that Jason / Guozhang is working on: https://issues.apache.org/jira/browse/KAFKA-2795 On Tue, Nov 10, 2015 at 11:39 AM, Jun Rao wrote: > Ewen, > > Thanks for reporting that. Will f

[jira] [Commented] (KAFKA-2790) Kafka 0.9.0 doc improvement

[ https://issues.apache.org/jira/browse/KAFKA-2790?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14999238#comment-14999238 ] Jun Rao commented on KAFKA-2790: In the upgrade section, we should mention that 0.9.0.0 dr

Build failed in Jenkins: kafka-trunk-jdk8 #126

See Changes: [wangguoz] MINOR: update system test readme -- Started by an SCM change [EnvInject] - Loading node environment variables. Building remotely on ubuntu-6 (docker Ubuntu ubuntu) in work

Build failed in Jenkins: kafka-trunk-jdk7 #797

See -- [...truncated 1561 lines...] kafka.coordinator.GroupCoordinatorResponseTest > testSyncGroupFromUnknownGroup PASSED kafka.coordinator.GroupCoordinatorResponseTest > testJoinGroupInconsistentProto

[GitHub] kafka pull request: KAFKA-2795: fix potential NPE in GroupMetadata...

GitHub user hachikuji opened a pull request: https://github.com/apache/kafka/pull/488 KAFKA-2795: fix potential NPE in GroupMetadataManager.addGroup You can merge this pull request into a Git repository by running: $ git pull https://github.com/hachikuji/kafka KAFKA-2795 Alte

[jira] [Commented] (KAFKA-2795) potential NPE in GroupMetadataManager

[ https://issues.apache.org/jira/browse/KAFKA-2795?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14999299#comment-14999299 ] ASF GitHub Bot commented on KAFKA-2795: --- GitHub user hachikuji opened a pull request

Re: [kafka-clients] Re: [VOTE] 0.9.0.0 Candiate 1

BTW. I created a Jenkins job for the 0.9 branch: https://builds.apache.org/job/kafka_0.9.0_jdk7/ Right now its pretty much identical to trunk, but since they may diverge, I figured we want to keep an eye on the branch separately. Gwen On Tue, Nov 10, 2015 at 11:39 AM, Jun Rao wrote: > Ewen, >

[jira] [Created] (KAFKA-2800) Update outdated dependencies

Grant Henke created KAFKA-2800: -- Summary: Update outdated dependencies Key: KAFKA-2800 URL: https://issues.apache.org/jira/browse/KAFKA-2800 Project: Kafka Issue Type: Improvement Affects Ve

[GitHub] kafka pull request: KAFKA-2795: fix potential NPE in GroupMetadata...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/488 --- 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 enabl

[jira] [Commented] (KAFKA-2795) potential NPE in GroupMetadataManager

[ https://issues.apache.org/jira/browse/KAFKA-2795?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14999345#comment-14999345 ] ASF GitHub Bot commented on KAFKA-2795: --- Github user asfgit closed the pull request

[jira] [Resolved] (KAFKA-2795) potential NPE in GroupMetadataManager

[ https://issues.apache.org/jira/browse/KAFKA-2795?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-2795. -- Resolution: Fixed Fix Version/s: 0.9.0.0 Issue resolved by pull request 488 [https://gith

Build failed in Jenkins: kafka_0.9.0_jdk7 #2

See Changes: [wangguoz] MINOR: update system test readme -- [...truncated 1513 lines...] kafka.security.auth.ZkAuthorizationTest > testDelete PASSED kafka.security.auth.ZkAuthorizationTest > testD

[jira] [Updated] (KAFKA-2796) add support for reassignment partition to specified logdir

[ https://issues.apache.org/jira/browse/KAFKA-2796?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-2796: - Assignee: Yonghui Yang (was: Neha Narkhede) > add support for reassignment partition to specified

[jira] [Updated] (KAFKA-2796) add support for reassignment partition to specified logdir

[ https://issues.apache.org/jira/browse/KAFKA-2796?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-2796: - Fix Version/s: (was: 0.9.0.0) 0.9.0.1 > add support for reassignment partit

Build failed in Jenkins: kafka-trunk-jdk8 #127

See Changes: [wangguoz] KAFKA-2795: fix potential NPE in GroupMetadataManager.addGroup -- Started by an SCM change [EnvInject] - Loading node environment variables. Building remotely on ubuntu3 (

[GitHub] kafka pull request: KAFKA-2788: Allow specifying principals with c...

GitHub user Parth-Brahmbhatt opened a pull request: https://github.com/apache/kafka/pull/489 KAFKA-2788: Allow specifying principals with comman in ACL CLI. You can merge this pull request into a Git repository by running: $ git pull https://github.com/Parth-Brahmbhatt/kafka K

[jira] [Commented] (KAFKA-2788) allow comma when specifying principals in AclCommand

[ https://issues.apache.org/jira/browse/KAFKA-2788?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14999356#comment-14999356 ] ASF GitHub Bot commented on KAFKA-2788: --- GitHub user Parth-Brahmbhatt opened a pull

[jira] [Commented] (KAFKA-2796) add support for reassignment partition to specified logdir

[ https://issues.apache.org/jira/browse/KAFKA-2796?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14999364#comment-14999364 ] Guozhang Wang commented on KAFKA-2796: -- I think there are some related KIP discussion

[GitHub] kafka pull request: KAFKA-2799: skip wakeup in the follow-up poll(...

GitHub user guozhangwang opened a pull request: https://github.com/apache/kafka/pull/490 KAFKA-2799: skip wakeup in the follow-up poll() call. You can merge this pull request into a Git repository by running: $ git pull https://github.com/guozhangwang/kafka K2799 Alternativel

[jira] [Commented] (KAFKA-2799) WakupException thrown in the followup poll() could lead to data loss

[ https://issues.apache.org/jira/browse/KAFKA-2799?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14999374#comment-14999374 ] ASF GitHub Bot commented on KAFKA-2799: --- GitHub user guozhangwang opened a pull requ

Jenkins build is back to normal : kafka-trunk-jdk7 #798

See

[GitHub] kafka pull request: KAFKA-2790: doc improvements

GitHub user gwenshap opened a pull request: https://github.com/apache/kafka/pull/491 KAFKA-2790: doc improvements You can merge this pull request into a Git repository by running: $ git pull https://github.com/gwenshap/kafka KAFKA-2790 Alternatively you can review and apply t

[jira] [Commented] (KAFKA-2790) Kafka 0.9.0 doc improvement

[ https://issues.apache.org/jira/browse/KAFKA-2790?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14999427#comment-14999427 ] ASF GitHub Bot commented on KAFKA-2790: --- GitHub user gwenshap opened a pull request:

[jira] [Commented] (KAFKA-2790) Kafka 0.9.0 doc improvement

[ https://issues.apache.org/jira/browse/KAFKA-2790?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14999433#comment-14999433 ] Gwen Shapira commented on KAFKA-2790: - Hey [~junrao], Take a look. I think I addresse

[GitHub] kafka pull request: KAFKA-2788: Allow specifying principals with c...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/489 --- 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 enabl

[jira] [Commented] (KAFKA-2788) allow comma when specifying principals in AclCommand

[ https://issues.apache.org/jira/browse/KAFKA-2788?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14999468#comment-14999468 ] ASF GitHub Bot commented on KAFKA-2788: --- Github user asfgit closed the pull request

Jenkins build is back to normal : kafka_0.9.0_jdk7 #3

See

[jira] [Resolved] (KAFKA-2788) allow comma when specifying principals in AclCommand

[ https://issues.apache.org/jira/browse/KAFKA-2788?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao resolved KAFKA-2788. Resolution: Fixed Issue resolved by pull request 489 [https://github.com/apache/kafka/pull/489] > allow com

[GitHub] kafka pull request: KAFKA-2793: Use ByteArrayDeserializer instead ...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/482 --- 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 enabl

[jira] [Commented] (KAFKA-2793) ConsoleConsumer crashes with new consumer when using keys because of incorrect deserializer

[ https://issues.apache.org/jira/browse/KAFKA-2793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14999498#comment-14999498 ] ASF GitHub Bot commented on KAFKA-2793: --- Github user asfgit closed the pull request

[GitHub] kafka pull request: KAFKA-2752: Add VerifiableSource/Sink connecto...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/432 --- 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 enabl

[jira] [Updated] (KAFKA-2752) Add clean bounce system test for distributed Copycat

[ https://issues.apache.org/jira/browse/KAFKA-2752?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-2752: - Fix Version/s: (was: 0.9.0.0) 0.9.0.1 > Add clean bounce system test for di

[jira] [Resolved] (KAFKA-2752) Add clean bounce system test for distributed Copycat

[ https://issues.apache.org/jira/browse/KAFKA-2752?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-2752. -- Resolution: Fixed Issue resolved by pull request 432 [https://github.com/apache/kafka/pull/432]

[jira] [Commented] (KAFKA-2752) Add clean bounce system test for distributed Copycat

[ https://issues.apache.org/jira/browse/KAFKA-2752?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14999504#comment-14999504 ] ASF GitHub Bot commented on KAFKA-2752: --- Github user asfgit closed the pull request

[jira] [Resolved] (KAFKA-2799) WakupException thrown in the followup poll() could lead to data loss

[ https://issues.apache.org/jira/browse/KAFKA-2799?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-2799. -- Resolution: Fixed Issue resolved by pull request 490 [https://github.com/apache/kafka/pull/490]

[GitHub] kafka pull request: KAFKA-2799: skip wakeup in the follow-up poll(...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/490 --- 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 enabl

[jira] [Commented] (KAFKA-2799) WakupException thrown in the followup poll() could lead to data loss

[ https://issues.apache.org/jira/browse/KAFKA-2799?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14999508#comment-14999508 ] ASF GitHub Bot commented on KAFKA-2799: --- Github user asfgit closed the pull request

[jira] [Resolved] (KAFKA-2793) ConsoleConsumer crashes with new consumer when using keys because of incorrect deserializer

[ https://issues.apache.org/jira/browse/KAFKA-2793?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira resolved KAFKA-2793. - Resolution: Fixed Fix Version/s: 0.9.0.0 Issue resolved by pull request 482 [https://github

[jira] [Created] (KAFKA-2801) Data read from network not processed by SSL transport layer

Rajini Sivaram created KAFKA-2801: - Summary: Data read from network not processed by SSL transport layer Key: KAFKA-2801 URL: https://issues.apache.org/jira/browse/KAFKA-2801 Project: Kafka

Build failed in Jenkins: kafka-trunk-jdk8 #128

See Changes: [junrao] KAFKA-2788; Allow specifying principals with comman in ACL CLI. [cshapi] KAFKA-2793: Use ByteArrayDeserializer instead of StringDeserializer for [wangguoz] KAFKA-2752: Add VerifiableSource/Sink connectors and rol

[GitHub] kafka pull request: KAFKA-2752: Follow up to fix checkstlye

GitHub user granthenke opened a pull request: https://github.com/apache/kafka/pull/492 KAFKA-2752: Follow up to fix checkstlye You can merge this pull request into a Git repository by running: $ git pull https://github.com/granthenke/kafka fix Alternatively you can review and

[jira] [Commented] (KAFKA-2752) Add clean bounce system test for distributed Copycat

[ https://issues.apache.org/jira/browse/KAFKA-2752?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14999574#comment-14999574 ] ASF GitHub Bot commented on KAFKA-2752: --- GitHub user granthenke opened a pull reques

[GitHub] kafka pull request: KAFKA-2801: Process any remaining data in SSL ...

GitHub user rajinisivaram opened a pull request: https://github.com/apache/kafka/pull/493 KAFKA-2801: Process any remaining data in SSL network read buffer after handshake Process any remaining data in the network read buffer in `SslTransportLayer` when `read()` is invoked. On hand

[jira] [Commented] (KAFKA-2801) Data read from network not processed by SSL transport layer

[ https://issues.apache.org/jira/browse/KAFKA-2801?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14999595#comment-14999595 ] ASF GitHub Bot commented on KAFKA-2801: --- GitHub user rajinisivaram opened a pull req

[jira] [Updated] (KAFKA-2801) Data read from network not processed by SSL transport layer

[ https://issues.apache.org/jira/browse/KAFKA-2801?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rajini Sivaram updated KAFKA-2801: -- Status: Patch Available (was: Open) Have run all existing unit tests. Can't think of an easy wa

[GitHub] kafka pull request: KAFKA-2752: Follow up to fix checkstlye

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/492 --- 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 enabl

[jira] [Commented] (KAFKA-2752) Add clean bounce system test for distributed Copycat

[ https://issues.apache.org/jira/browse/KAFKA-2752?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14999616#comment-14999616 ] ASF GitHub Bot commented on KAFKA-2752: --- Github user asfgit closed the pull request

[jira] [Updated] (KAFKA-1892) System tests for the new consumer and co-ordinator

[ https://issues.apache.org/jira/browse/KAFKA-1892?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-1892: - Resolution: Won't Fix Status: Resolved (was: Patch Available) We have added integration t

  1   2   >