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

2016-03-03 Thread Apache Jenkins Server
See Changes: [wangguoz] HOTFIX: Fix checkstyle failure in KStreams by providing fully qualified -- Started by an SCM change [EnvInject] - Loading node environment variables. Building remotely on

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

2016-03-03 Thread Apache Jenkins Server
See Changes: [wangguoz] HOTFIX: Fix checkstyle failure in KStreams by providing fully qualified -- [...truncated 1768 lines...] kafka.log.BrokerCompressionTest > testBrokerSideCompression[1] P

[jira] [Commented] (KAFKA-2636) Producer connectivity obscured connection failure logging

2016-03-03 Thread Rajesh Nair (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2636?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15177559#comment-15177559 ] Rajesh Nair commented on KAFKA-2636: [~gwenshap] You reasoning sounds correct! But t

[jira] [Created] (KAFKA-3324) NullPointerException in StreamPartitionAssignor (Kafka Streams)

2016-03-03 Thread Michael Noll (JIRA)
Michael Noll created KAFKA-3324: --- Summary: NullPointerException in StreamPartitionAssignor (Kafka Streams) Key: KAFKA-3324 URL: https://issues.apache.org/jira/browse/KAFKA-3324 Project: Kafka

[GitHub] kafka pull request: KAFKA-3324: NullPointerException in StreamPart...

2016-03-03 Thread miguno
GitHub user miguno opened a pull request: https://github.com/apache/kafka/pull/1001 KAFKA-3324: NullPointerException in StreamPartitionAssignor You can merge this pull request into a Git repository by running: $ git pull https://github.com/miguno/kafka KAFKA-3324 Alternativel

[jira] [Commented] (KAFKA-3324) NullPointerException in StreamPartitionAssignor (Kafka Streams)

2016-03-03 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3324?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15177620#comment-15177620 ] ASF GitHub Bot commented on KAFKA-3324: --- GitHub user miguno opened a pull request:

[jira] [Updated] (KAFKA-3324) NullPointerException in StreamPartitionAssignor (Kafka Streams)

2016-03-03 Thread Michael Noll (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3324?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Michael Noll updated KAFKA-3324: Description: KAFKA-3311 changed {{streams/src/main/java/org/apache/kafka/streams/processor/internal

[VOTE] KIP-43: Kafka SASL enhancements

2016-03-03 Thread Rajini Sivaram
I would like to start the voting process for *KIP-43: Kafka SASL enhancements*. This KIP extends the SASL implementation in Kafka to support new SASL mechanisms to enable Kafka to be integrated with different authentication servers. The KIP is available here for reference: https://cwiki.apache.org

[GitHub] kafka pull request: KAFKA-3324: NullPointerException in StreamPart...

2016-03-03 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/1001 --- 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 enab

[jira] [Commented] (KAFKA-3324) NullPointerException in StreamPartitionAssignor (Kafka Streams)

2016-03-03 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3324?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15177663#comment-15177663 ] ASF GitHub Bot commented on KAFKA-3324: --- Github user asfgit closed the pull request

[jira] [Resolved] (KAFKA-3324) NullPointerException in StreamPartitionAssignor (Kafka Streams)

2016-03-03 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3324?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava resolved KAFKA-3324. -- Resolution: Fixed Fix Version/s: 0.10.0.0 Issue resolved by pull request

[jira] [Created] (KAFKA-3325) Out of date instructions in quickstart guide

2016-03-03 Thread Duncan Sands (JIRA)
Duncan Sands created KAFKA-3325: --- Summary: Out of date instructions in quickstart guide Key: KAFKA-3325 URL: https://issues.apache.org/jira/browse/KAFKA-3325 Project: Kafka Issue Type: Bug

Re: [jira] [Created] (KAFKA-3325) Out of date instructions in quickstart guide

2016-03-03 Thread Ismael Juma
Thanks Duncan, would you like to submit a pull request to update the docs? I suggest we remove port from the example as it's redundant if we set listeners. Ismael On 3 Mar 2016 11:09, "Duncan Sands (JIRA)" wrote: > Duncan Sands created KAFKA-3325: > --- > >

[jira] [Commented] (KAFKA-3325) Out of date instructions in quickstart guide

2016-03-03 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3325?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15177683#comment-15177683 ] Ismael Juma commented on KAFKA-3325: Thanks Duncan, would you like to submit a pull re

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

2016-03-03 Thread Apache Jenkins Server
See Changes: [me] KAFKA-3324; NullPointerException in StreamPartitionAssignor -- [...truncated 48 lines...] Building project 'core' with Scala version 2.10.6 :kafka-trunk-jdk7:clients:compileJav

[GitHub] kafka pull request: KAFKA-3325: Out of date instructions in quicks...

2016-03-03 Thread CunningBaldrick
GitHub user CunningBaldrick opened a pull request: https://github.com/apache/kafka/pull/1002 KAFKA-3325: Out of date instructions in quickstart guide Adjust the listeners property rather than the port. Following the original instructions would result in all of the brokers being sta

[jira] [Commented] (KAFKA-3325) Out of date instructions in quickstart guide

2016-03-03 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3325?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15177745#comment-15177745 ] ASF GitHub Bot commented on KAFKA-3325: --- GitHub user CunningBaldrick opened a pull r

[jira] [Commented] (KAFKA-3325) Out of date instructions in quickstart guide

2016-03-03 Thread Duncan Sands (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3325?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15177750#comment-15177750 ] Duncan Sands commented on KAFKA-3325: - Here you go: https://github.com/apache/kafka/pu

[jira] [Updated] (KAFKA-3281) Improve message of stop scripts when no processes are running

2016-03-03 Thread Sasaki Toru (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3281?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sasaki Toru updated KAFKA-3281: --- Assignee: Sasaki Toru Status: Patch Available (was: Open) > Improve message of stop scripts whe

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

2016-03-03 Thread Apache Jenkins Server
See Changes: [me] KAFKA-3324; NullPointerException in StreamPartitionAssignor -- [...truncated 2973 lines...] kafka.log.LogTest > testTruncateTo PASSED kafka.log.LogTest > testCleanShutdownFile

[jira] [Updated] (KAFKA-3296) All consumer reads hang indefinately

2016-03-03 Thread Simon Cooper (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3296?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Simon Cooper updated KAFKA-3296: Attachment: controller.zip Attached debug log kafka controller logs. Also attached the zookeeper dae

[GitHub] kafka pull request: MINOR: Fix typos in docs

2016-03-03 Thread sasakitoa
GitHub user sasakitoa opened a pull request: https://github.com/apache/kafka/pull/1003 MINOR: Fix typos in docs You can merge this pull request into a Git repository by running: $ git pull https://github.com/sasakitoa/kafka Fix_typo_in_docs Alternatively you can review and ap

[jira] [Created] (KAFKA-3326) Error: A JNI error has occurred, please check your installation and try again

2016-03-03 Thread iyaozhen (JIRA)
iyaozhen created KAFKA-3326: --- Summary: Error: A JNI error has occurred, please check your installation and try again Key: KAFKA-3326 URL: https://issues.apache.org/jira/browse/KAFKA-3326 Project: Kafka

[jira] [Updated] (KAFKA-3326) Error: A JNI error has occurred, please check your installation and try again

2016-03-03 Thread iyaozhen (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3326?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] iyaozhen updated KAFKA-3326: Issue Type: Bug (was: Wish) > Error: A JNI error has occurred, please check your installation and try again

[GitHub] kafka pull request: HOTFIX: Avoid NPE in StreamsPartitionAssignor

2016-03-03 Thread guozhangwang
GitHub user guozhangwang opened a pull request: https://github.com/apache/kafka/pull/1004 HOTFIX: Avoid NPE in StreamsPartitionAssignor You can merge this pull request into a Git repository by running: $ git pull https://github.com/guozhangwang/kafka KStreamPANPE Alternativel

[jira] [Commented] (KAFKA-3236) Honor Producer Configuration "block.on.buffer.full"

2016-03-03 Thread Thomas Graves (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3236?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15178094#comment-15178094 ] Thomas Graves commented on KAFKA-3236: -- So you are thinking you would rather not have

[GitHub] kafka pull request: KAFKA-2934: Offset storage file configuration ...

2016-03-03 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/734 --- 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-2934) Offset storage file configuration in Connect standalone mode is not included in StandaloneConfig

2016-03-03 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2934?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava resolved KAFKA-2934. -- Resolution: Fixed Fix Version/s: 0.10.0.0 Issue resolved by pull request

[jira] [Commented] (KAFKA-2934) Offset storage file configuration in Connect standalone mode is not included in StandaloneConfig

2016-03-03 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2934?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15178112#comment-15178112 ] ASF GitHub Bot commented on KAFKA-2934: --- Github user asfgit closed the pull request

[GitHub] kafka pull request: HOTFIX: Avoid NPE in StreamsPartitionAssignor

2016-03-03 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/1004 --- 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 enab

[GitHub] kafka pull request: WIP - KAFKA-3266: List/Alter Acls - protocol a...

2016-03-03 Thread granthenke
GitHub user granthenke opened a pull request: https://github.com/apache/kafka/pull/1005 WIP - KAFKA-3266: List/Alter Acls - protocol and server side implemen… …tation You can merge this pull request into a Git repository by running: $ git pull https://github.com/granthenke/

[jira] [Commented] (KAFKA-3266) List/Alter Acls - protocol and server side implementation

2016-03-03 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3266?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15178151#comment-15178151 ] ASF GitHub Bot commented on KAFKA-3266: --- GitHub user granthenke opened a pull reques

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

2016-03-03 Thread Apache Jenkins Server
See Changes: [me] KAFKA-2934; Offset storage file configuration in Connect standalone mode [wangguoz] HOTFIX: Avoid NPE in StreamsPartitionAssignor -- Started by an SCM change [EnvInject] - Load

[jira] [Created] (KAFKA-3327) Warning from kafka mirror maker about ssl properties not valid

2016-03-03 Thread Munir Khan (JIRA)
Munir Khan created KAFKA-3327: - Summary: Warning from kafka mirror maker about ssl properties not valid Key: KAFKA-3327 URL: https://issues.apache.org/jira/browse/KAFKA-3327 Project: Kafka Issue

[jira] [Created] (KAFKA-3328) SimpleAclAuthorizer can lose ACLs with frequent add/remove calls

2016-03-03 Thread Grant Henke (JIRA)
Grant Henke created KAFKA-3328: -- Summary: SimpleAclAuthorizer can lose ACLs with frequent add/remove calls Key: KAFKA-3328 URL: https://issues.apache.org/jira/browse/KAFKA-3328 Project: Kafka I

[jira] [Commented] (KAFKA-3323) Negative offsets in Log Segment Index files due to Integer overflow when compaction is enabled

2016-03-03 Thread Michael Schiff (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3323?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15178187#comment-15178187 ] Michael Schiff commented on KAFKA-3323: --- Regarding solutions: One alternative is to

Authorizer questions

2016-03-03 Thread Grant Henke
I am working on the List/Alter ACLs patch ( https://github.com/apache/kafka/pull/1005) for KIP-4 and have a few questions around expectations for an Authorizer implementation: - What is the expected behavior when I add the same ACL twice? - What is the expected behavior when I remove an ACL

[jira] [Updated] (KAFKA-3328) SimpleAclAuthorizer can lose ACLs with frequent add/remove calls

2016-03-03 Thread Grant Henke (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3328?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Grant Henke updated KAFKA-3328: --- Description: Currently when adding or removing an ACL with the SimpleAclAuthorizer the following high

[jira] [Comment Edited] (KAFKA-3323) Negative offsets in Log Segment Index files due to Integer overflow when compaction is enabled

2016-03-03 Thread Michael Schiff (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3323?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15178187#comment-15178187 ] Michael Schiff edited comment on KAFKA-3323 at 3/3/16 5:56 PM: -

Re: [DISCUSS] KIP-35 - Retrieve protocol version

2016-03-03 Thread Ashish Singh
> Also, the release version could be included in the broker information in the topic metadata request which would save the need for the additional round trip on every reconnect. Wouldn't this cause a catch-22 situation, where you need to know protocol version of metadata request to get supported p

Re: [DISCUSS] KIP-35 - Retrieve protocol version

2016-03-03 Thread Ashish Singh
> I think using Kafka release version makes sense. More particularly, we can use the ApiVersion and this will cover all the interval version as well. In KAFKA-3025, we added the ApiVersion to message format version mapping, We can add the ApiKey to version mapping to ApiVersion as well. We can move

[jira] [Created] (KAFKA-3329) Validation script to test expected behavior of Authorizer implementations

2016-03-03 Thread Grant Henke (JIRA)
Grant Henke created KAFKA-3329: -- Summary: Validation script to test expected behavior of Authorizer implementations Key: KAFKA-3329 URL: https://issues.apache.org/jira/browse/KAFKA-3329 Project: Kafka

[jira] [Commented] (KAFKA-3236) Honor Producer Configuration "block.on.buffer.full"

2016-03-03 Thread Jiangjie Qin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3236?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15178334#comment-15178334 ] Jiangjie Qin commented on KAFKA-3236: - [~tgraves] I think we are on the same page that

Re: Authorizer questions

2016-03-03 Thread Grant Henke
Related to these questions, I create a jira to track testing/validating these expectations for both the internal SimpleAuthorizer and any third party implemented authorizer: KAFKA-3329 : Validation script to test expected behavior of Authorizer imp

[jira] [Updated] (KAFKA-1215) Rack-Aware replica assignment option

2016-03-03 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1215?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-1215: --- Priority: Critical (was: Blocker) > Rack-Aware replica assignment option > --

[jira] [Updated] (KAFKA-3323) Negative offsets in Log Segment Index files due to Integer overflow when compaction is enabled

2016-03-03 Thread Michael Schiff (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3323?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Michael Schiff updated KAFKA-3323: -- Description: Once the Offset Index has negative offset values, the binary search for position l

[jira] [Updated] (KAFKA-3323) Negative offsets in Log Segment Index files due to Integer overflow when compaction is enabled

2016-03-03 Thread Michael Schiff (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3323?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Michael Schiff updated KAFKA-3323: -- Description: Once the Offset Index has negative offset values, the binary search for position l

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

2016-03-03 Thread Apache Jenkins Server
See

[jira] [Updated] (KAFKA-3316) Add Connect REST API to list available connector classes

2016-03-03 Thread Gwen Shapira (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3316?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira updated KAFKA-3316: Reviewer: Gwen Shapira > Add Connect REST API to list available connector classes >

[jira] [Updated] (KAFKA-2370) Add pause/unpause connector support

2016-03-03 Thread Gwen Shapira (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2370?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira updated KAFKA-2370: Reviewer: Gwen Shapira > Add pause/unpause connector support > --- >

[jira] [Updated] (KAFKA-3314) Add CDDL license to LICENSE and NOTICE file

2016-03-03 Thread Gwen Shapira (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3314?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira updated KAFKA-3314: Reviewer: Gwen Shapira > Add CDDL license to LICENSE and NOTICE file > -

[jira] [Updated] (KAFKA-3303) Pass partial record metadata to Interceptor onAcknowledgement in case of errors

2016-03-03 Thread Gwen Shapira (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3303?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira updated KAFKA-3303: Reviewer: Jun Rao > Pass partial record metadata to Interceptor onAcknowledgement in case of > erro

[jira] [Updated] (KAFKA-3197) Producer can send message out of order even when in flight request is set to 1.

2016-03-03 Thread Gwen Shapira (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3197?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira updated KAFKA-3197: Reviewer: Jun Rao > Producer can send message out of order even when in flight request is set to >

[jira] [Updated] (KAFKA-3188) Add system test for KIP-31 and KIP-32 - Compatibility Test

2016-03-03 Thread Gwen Shapira (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3188?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira updated KAFKA-3188: Reviewer: Ewen Cheslack-Postava > Add system test for KIP-31 and KIP-32 - Compatibility Test > -

[jira] [Updated] (KAFKA-3202) Add system test for KIP-31 and KIP-32 - Change message format version on the fly

2016-03-03 Thread Gwen Shapira (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3202?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira updated KAFKA-3202: Assignee: Anna Povzner Reviewer: Ewen Cheslack-Postava > Add system test for KIP-31 and KIP-32 -

[jira] [Updated] (KAFKA-3201) Add system test for KIP-31 and KIP-32 - Upgrade Test

2016-03-03 Thread Gwen Shapira (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3201?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira updated KAFKA-3201: Reviewer: Ewen Cheslack-Postava > Add system test for KIP-31 and KIP-32 - Upgrade Test > ---

[jira] [Updated] (KAFKA-3283) Consider marking the new consumer as production-ready

2016-03-03 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3283?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-3283: --- Priority: Critical (was: Major) > Consider marking the new consumer as production-ready > ---

[jira] [Updated] (KAFKA-2658) Implement SASL/PLAIN

2016-03-03 Thread Gwen Shapira (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2658?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira updated KAFKA-2658: Reviewer: Jun Rao > Implement SASL/PLAIN > > > Key: KAFKA-2658

[jira] [Updated] (KAFKA-3190) KafkaProducer should not invoke callback in send()

2016-03-03 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3190?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-3190: --- Priority: Critical (was: Major) > KafkaProducer should not invoke callback in send() > --

[jira] [Updated] (KAFKA-3006) Make collection default container type for sequences in the consumer API

2016-03-03 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3006?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-3006: --- Fix Version/s: 0.10.0.0 > Make collection default container type for sequences in the consumer API > -

[jira] [Updated] (KAFKA-3006) Make collection default container type for sequences in the consumer API

2016-03-03 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3006?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-3006: --- Priority: Critical (was: Major) > Make collection default container type for sequences in the consume

[jira] [Updated] (KAFKA-1215) Rack-Aware replica assignment option

2016-03-03 Thread Gwen Shapira (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1215?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira updated KAFKA-1215: Reviewer: Jun Rao > Rack-Aware replica assignment option > > >

[jira] [Commented] (KAFKA-3006) Make collection default container type for sequences in the consumer API

2016-03-03 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3006?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15178407#comment-15178407 ] Ismael Juma commented on KAFKA-3006: Marked this as critical with a fix version of 0.1

[jira] [Updated] (KAFKA-3284) Consider removing beta label in security documentation

2016-03-03 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3284?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-3284: --- Priority: Critical (was: Major) > Consider removing beta label in security documentation > --

[jira] [Updated] (KAFKA-3283) Consider marking the new consumer as production-ready

2016-03-03 Thread Gwen Shapira (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3283?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira updated KAFKA-3283: Assignee: Jason Gustafson Reviewer: Gwen Shapira > Consider marking the new consumer as producti

[jira] [Updated] (KAFKA-2982) Mark the old Scala producer and related classes as deprecated

2016-03-03 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2982?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-2982: --- Priority: Critical (was: Major) > Mark the old Scala producer and related classes as deprecated > ---

[jira] [Updated] (KAFKA-3190) KafkaProducer should not invoke callback in send()

2016-03-03 Thread Gwen Shapira (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3190?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira updated KAFKA-3190: Reviewer: Guozhang Wang > KafkaProducer should not invoke callback in send() > -

[jira] [Updated] (KAFKA-3006) Make collection default container type for sequences in the consumer API

2016-03-03 Thread Gwen Shapira (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3006?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira updated KAFKA-3006: Assignee: Pierre-Yves Ritschard Reviewer: Jason Gustafson > Make collection default container ty

[jira] [Updated] (KAFKA-2982) Mark the old Scala producer and related classes as deprecated

2016-03-03 Thread Gwen Shapira (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2982?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira updated KAFKA-2982: Assignee: Grant Henke Reviewer: Gwen Shapira > Mark the old Scala producer and related classes a

[jira] [Updated] (KAFKA-3304) KIP-35 - Retrieving protocol version

2016-03-03 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3304?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-3304: --- Priority: Critical (was: Major) > KIP-35 - Retrieving protocol version >

[jira] [Updated] (KAFKA-3304) KIP-35 - Retrieving protocol version

2016-03-03 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3304?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-3304: --- Fix Version/s: 0.10.0.0 > KIP-35 - Retrieving protocol version >

[jira] [Updated] (KAFKA-3284) Consider removing beta label in security documentation

2016-03-03 Thread Gwen Shapira (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3284?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira updated KAFKA-3284: Reviewer: Gwen Shapira > Consider removing beta label in security documentation > --

Re: [DISCUSS] KIP-35 - Retrieve protocol version

2016-03-03 Thread Ashish Singh
On Wed, Mar 2, 2016 at 8:29 PM, Becket Qin wrote: > Hi Jason, > > I was thinking that every time when we connect to a broker, we first send > the version check request. (The version check request itself should be very > simple and never changes across all server releases.) This does add an > addi

[jira] [Updated] (KAFKA-3304) KIP-35 - Retrieving protocol version

2016-03-03 Thread Gwen Shapira (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3304?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira updated KAFKA-3304: Reviewer: Magnus Edenhill > KIP-35 - Retrieving protocol version > -

[jira] [Commented] (KAFKA-3304) KIP-35 - Retrieving protocol version

2016-03-03 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3304?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15178430#comment-15178430 ] Ismael Juma commented on KAFKA-3304: Tentatively setting fix version of 0.10.0.0 as co

[jira] [Commented] (KAFKA-3329) Validation script to test expected behavior of Authorizer implementations

2016-03-03 Thread Ashish K Singh (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3329?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15178443#comment-15178443 ] Ashish K Singh commented on KAFKA-3329: --- Do you think adding ducktape tests will wor

Re: Authorizer questions

2016-03-03 Thread Ashish Singh
Grant, thanks for finding this. Below are my thoughts. On Thu, Mar 3, 2016 at 9:33 AM, Grant Henke wrote: > I am working on the List/Alter ACLs patch ( > https://github.com/apache/kafka/pull/1005) for KIP-4 and have a few > questions around expectations for an Authorizer implementation: > >-

[jira] [Commented] (KAFKA-3202) Add system test for KIP-31 and KIP-32 - Change message format version on the fly

2016-03-03 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3202?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15178471#comment-15178471 ] Ismael Juma commented on KAFKA-3202: [~becket_qin], do you have cycles to help with th

Re: Authorizer questions

2016-03-03 Thread Ashish Singh
Great idea. Copying my comment from the JIRA. Do you think adding ducktape tests will work? It will probably require ducktape to allow adding resources, like JARs, config files, etc. Geoff Anderson is it possible to do that? ​

[jira] [Commented] (KAFKA-3323) Negative offsets in Log Segment Index files due to Integer overflow when compaction is enabled

2016-03-03 Thread Konstantin Zadorozhny (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3323?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15178479#comment-15178479 ] Konstantin Zadorozhny commented on KAFKA-3323: -- Is this issue is a duplicate

[jira] [Updated] (KAFKA-3314) Add CDDL license to LICENSE and NOTICE file

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

[GitHub] kafka pull request: KAFKA-3314: Add CDDL license to LICENSE and NO...

2016-03-03 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/997 --- 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-3314) Add CDDL license to LICENSE and NOTICE file

2016-03-03 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3314?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15178481#comment-15178481 ] ASF GitHub Bot commented on KAFKA-3314: --- Github user asfgit closed the pull request

[GitHub] kafka pull request: MINOR: Fix typos in docs

2016-03-03 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/1003 --- 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 enab

[GitHub] kafka pull request: KAFKA-3325: Out of date instructions in quicks...

2016-03-03 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/1002 --- 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 enab

[jira] [Resolved] (KAFKA-3325) Out of date instructions in quickstart guide

2016-03-03 Thread Gwen Shapira (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3325?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira resolved KAFKA-3325. - Resolution: Fixed Fix Version/s: 0.10.0.0 Issue resolved by pull request 1002 [https://gith

[jira] [Commented] (KAFKA-3325) Out of date instructions in quickstart guide

2016-03-03 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3325?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15178500#comment-15178500 ] ASF GitHub Bot commented on KAFKA-3325: --- Github user asfgit closed the pull request

[jira] [Assigned] (KAFKA-3328) SimpleAclAuthorizer can lose ACLs with frequent add/remove calls

2016-03-03 Thread Grant Henke (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3328?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Grant Henke reassigned KAFKA-3328: -- Assignee: Grant Henke > SimpleAclAuthorizer can lose ACLs with frequent add/remove calls >

[jira] [Commented] (KAFKA-3328) SimpleAclAuthorizer can lose ACLs with frequent add/remove calls

2016-03-03 Thread Grant Henke (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3328?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15178501#comment-15178501 ] Grant Henke commented on KAFKA-3328: I think I will work on this as it is affecting my

[jira] [Commented] (KAFKA-3328) SimpleAclAuthorizer can lose ACLs with frequent add/remove calls

2016-03-03 Thread Ashish K Singh (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3328?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15178513#comment-15178513 ] Ashish K Singh commented on KAFKA-3328: --- Sounds good, however can we do lazy writes

[jira] [Commented] (KAFKA-3328) SimpleAclAuthorizer can lose ACLs with frequent add/remove calls

2016-03-03 Thread Ashish K Singh (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3328?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15178516#comment-15178516 ] Ashish K Singh commented on KAFKA-3328: --- [~parth.brahmbhatt] might have some thought

[jira] [Commented] (KAFKA-3329) Validation script to test expected behavior of Authorizer implementations

2016-03-03 Thread Grant Henke (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3329?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15178613#comment-15178613 ] Grant Henke commented on KAFKA-3329: [~singhashish] Sure ducktape tests would work and

[GitHub] kafka pull request: KAFKA-3328: SimpleAclAuthorizer can lose ACLs ...

2016-03-03 Thread granthenke
GitHub user granthenke opened a pull request: https://github.com/apache/kafka/pull/1006 KAFKA-3328: SimpleAclAuthorizer can lose ACLs with frequent add/remov… …e calls Changes the SimpleAclAuthorizer to: - Always read state from Zookeeper before updating acls - U

[jira] [Commented] (KAFKA-3328) SimpleAclAuthorizer can lose ACLs with frequent add/remove calls

2016-03-03 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3328?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15178633#comment-15178633 ] ASF GitHub Bot commented on KAFKA-3328: --- GitHub user granthenke opened a pull reques

[jira] [Commented] (KAFKA-2636) Producer connectivity obscured connection failure logging

2016-03-03 Thread Gwen Shapira (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2636?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15178642#comment-15178642 ] Gwen Shapira commented on KAFKA-2636: - async send doesn't throw an exception (because

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

2016-03-03 Thread Apache Jenkins Server
See Changes: [cshapi] KAFKA-3314: Add CDDL license to LICENSE and NOTICE file [cshapi] MINOR: Fix typos in docs [cshapi] KAFKA-3325: Out of date instructions in quickstart guide -- [...truncat

Jenkins build is back to normal : kafka-trunk-jdk8 #415

2016-03-03 Thread Apache Jenkins Server
See

[GitHub] kafka pull request: HOTFIX: Include RocksDB dependency in release ...

2016-03-03 Thread miguno
GitHub user miguno opened a pull request: https://github.com/apache/kafka/pull/1007 HOTFIX: Include RocksDB dependency in release tarballs Without this change `./gradlew releaseTarGz` (and its variants) will not include the RocksDB jar in Kafka's `libs/` folder. @guozhangwa

[GitHub] kafka pull request: HOTFIX: Include RocksDB dependency in release ...

2016-03-03 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/1007 --- 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 enab

[jira] [Reopened] (KAFKA-3290) WorkerSourceTask testCommit transient failure

2016-03-03 Thread Jason Gustafson (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3290?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson reopened KAFKA-3290: Looks like this is still failing: https://jenkins.confluent.io/job/kafka-trunk/576/console > W

  1   2   >