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

[ https://issues.apache.org/jira/browse/KAFKA-3201?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anna Povzner updated KAFKA-3201: Status: Patch Available (was: In Progress) Verified that upgrade tests are passing on Jenkins (ran

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

[ https://issues.apache.org/jira/browse/KAFKA-3303?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on KAFKA-3303 started by Anna Povzner. --- > Pass partial record metadata to Interceptor onAcknowledgement in case of > error

[jira] [Comment Edited] (KAFKA-3252) compression type for a topic should be used during log compaction

[ https://issues.apache.org/jira/browse/KAFKA-3252?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15179373#comment-15179373 ] Manikumar Reddy edited comment on KAFKA-3252 at 3/4/16 5:45 AM:

[jira] [Commented] (KAFKA-3252) compression type for a topic should be used during log compaction

[ https://issues.apache.org/jira/browse/KAFKA-3252?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15179373#comment-15179373 ] Manikumar Reddy commented on KAFKA-3252: @ [~singhashish], [~junrao] This issue i

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

I talked with Jay about this KIP briefly this morning, so let me try to summarize the discussion (I'm sure he'll jump in if I get anything wrong). Apologies in advance for the length. I think we both share some skepticism that a request with all the supported versions of all the request APIs is go

Re: [VOTE] Deprecating the old Scala producers for 0.10.0.0

+1 (non-binding) On Thu, Mar 3, 2016 at 9:39 PM, Ashish Singh wrote: > +1 (non-binding) > > On Thu, Mar 3, 2016 at 4:57 PM, Becket Qin wrote: > > > +1 (non-binding) > > > > On Thu, Mar 3, 2016 at 3:39 PM, Gwen Shapira wrote: > > > > > +1 > > > > > > On Thu, Mar 3, 2016 at 2:36 PM, Ismael Juma

[jira] [Resolved] (KAFKA-2315) Kafka binary distribution may contain incorrect dependencies

[ https://issues.apache.org/jira/browse/KAFKA-2315?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar Reddy resolved KAFKA-2315. Resolution: Fixed Fix Version/s: 0.9.0.1 This got fixed in 0.9 release. > Kafka bina

Re: [VOTE] Deprecating the old Scala producers for 0.10.0.0

+1 (non-binding) On Thu, Mar 3, 2016 at 4:57 PM, Becket Qin wrote: > +1 (non-binding) > > On Thu, Mar 3, 2016 at 3:39 PM, Gwen Shapira wrote: > > > +1 > > > > On Thu, Mar 3, 2016 at 2:36 PM, Ismael Juma wrote: > > > Hi all, > > > > > > The new Java producer was introduced in 0.8.2.0 (released

[jira] [Created] (KAFKA-3331) Refactor TopicCommand to make it testable and add unit tests

Ashish K Singh created KAFKA-3331: - Summary: Refactor TopicCommand to make it testable and add unit tests Key: KAFKA-3331 URL: https://issues.apache.org/jira/browse/KAFKA-3331 Project: Kafka

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

See

[jira] [Commented] (KAFKA-3247) kafka-topic tool can use an option to see just "unbalanced partitions"

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

[GitHub] kafka pull request: KAFKA-3247: Add option to see unbalanced parti...

GitHub user SinghAsDev opened a pull request: https://github.com/apache/kafka/pull/1011 KAFKA-3247: Add option to see unbalanced partitions via kafka-topic tool You can merge this pull request into a Git repository by running: $ git pull https://github.com/SinghAsDev/kafka KAF

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

[ https://issues.apache.org/jira/browse/KAFKA-3281?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira updated KAFKA-3281: Resolution: Fixed Fix Version/s: 0.10.0.0 Status: Resolved (was: Patch Available)

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

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

[GitHub] kafka pull request: KAFKA-3281: Improve message of *-server-stop.s...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/971 --- 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-3187) Make kafka-acls.sh help messages more generic.

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

[GitHub] kafka pull request: KAFKA-3187: Make kafka-acls.sh help messages m...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/892 --- 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-3187) Make kafka-acls.sh help messages more generic.

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

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

See

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

See Changes: [cshapi] KAFKA-3290: fix race condition with worker task shutdown and mock [cshapi] KAFKA-3286: Add plugin to quickly check for outdated dependencies -- [...truncated 3608 lines...]

Re: [VOTE] Deprecating the old Scala producers for 0.10.0.0

+1 (non-binding) On Thu, Mar 3, 2016 at 3:39 PM, Gwen Shapira wrote: > +1 > > On Thu, Mar 3, 2016 at 2:36 PM, Ismael Juma wrote: > > Hi all, > > > > The new Java producer was introduced in 0.8.2.0 (released in February > > 2015). It has become the default implementation for various tools since

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

[ https://issues.apache.org/jira/browse/KAFKA-3236?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Graves resolved KAFKA-3236. -- Resolution: Won't Fix Ok, closing this for now then. > Honor Producer Configuration "block.on.b

[jira] [Commented] (KAFKA-3252) compression type for a topic should be used during log compaction

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

[GitHub] kafka pull request: KAFKA-3252: Compression type from broker confi...

GitHub user SinghAsDev opened a pull request: https://github.com/apache/kafka/pull/1010 KAFKA-3252: Compression type from broker config should be used during log compaction. You can merge this pull request into a Git repository by running: $ git pull https://github.com/SinghA

[GitHub] kafka pull request: KAFKA-3310: Fix for NPEs observed when throttl...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/989 --- 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-3310) fetch requests can trigger repeated NPE when quota is enabled

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

[jira] [Commented] (KAFKA-3310) fetch requests can trigger repeated NPE when quota is enabled

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

[jira] [Commented] (KAFKA-1696) Kafka should be able to generate Hadoop delegation tokens

[ https://issues.apache.org/jira/browse/KAFKA-1696?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15178887#comment-15178887 ] Eron Wright commented on KAFKA-1696: - I'd like clarification on whether renewal is po

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

Hi Ashish, In approach (1), the clients will still be able to talked to multiple versions of Kafka brokers as long as the clients version is not higher than the broker version, right? >From Spark's point of view, it seems the difference is whether Spark can independently update their Kafka client

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

See Changes: [junrao] HOTFIX: Include RocksDB dependency in release tarballs -- [...truncated 5626 lines...] org.apache.kafka.connect.storage.KafkaOffsetBackingStoreTest > testGetSet PASSED or

Re: [VOTE] Deprecating the old Scala producers for 0.10.0.0

+1 On Thu, Mar 3, 2016 at 2:36 PM, Ismael Juma wrote: > Hi all, > > The new Java producer was introduced in 0.8.2.0 (released in February > 2015). It has become the default implementation for various tools since > 0.9.0.0 (released in October 2015) and it is the only implementation with > support

[jira] [Updated] (KAFKA-3330) Truncate log cleaner offset checkpoint if the log is truncated

[ https://issues.apache.org/jira/browse/KAFKA-3330?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-3330: --- Fix Version/s: 0.10.0.0 > Truncate log cleaner offset checkpoint if the log is truncated > ---

[jira] [Updated] (KAFKA-3330) Truncate log cleaner offset checkpoint if the log is truncated

[ https://issues.apache.org/jira/browse/KAFKA-3330?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-3330: --- Priority: Critical (was: Major) > Truncate log cleaner offset checkpoint if the log is truncated > --

[jira] [Commented] (KAFKA-3286) Add plugin to quickly check for outdated dependencies

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

[jira] [Updated] (KAFKA-3286) Add plugin to quickly check for outdated dependencies

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

[GitHub] kafka pull request: KAFKA-3286: Add plugin to quickly check for ou...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/973 --- 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-3330) Truncate log cleaner offset checkpoint if the log is truncated

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

[GitHub] kafka pull request: KAFKA-3330; Truncate log cleaner offset checkp...

GitHub user lindong28 opened a pull request: https://github.com/apache/kafka/pull/1009 KAFKA-3330; Truncate log cleaner offset checkpoint if the log is truncated @becketqin Can you take a look? You can merge this pull request into a Git repository by running: $ git pull https:/

[jira] [Updated] (KAFKA-3330) Truncate log cleaner offset checkpoint if the log is truncated

[ https://issues.apache.org/jira/browse/KAFKA-3330?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-3330: Summary: Truncate log cleaner offset checkpoint if the log is truncated (was: Decrease log cleaner offset c

Re: [VOTE] Deprecating the old Scala producers for 0.10.0.0

+1 ~ Joestein On Mar 3, 2016 3:01 PM, "Neha Narkhede" wrote: > +1 > > On Thu, Mar 3, 2016 at 2:36 PM, Ismael Juma wrote: > > > Hi all, > > > > The new Java producer was introduced in 0.8.2.0 (released in February > > 2015). It has become the default implementation for various tools since > > 0.

Re: [VOTE] Deprecating the old Scala producers for 0.10.0.0

+1 On Thu, Mar 3, 2016 at 2:36 PM, Ismael Juma wrote: > Hi all, > > The new Java producer was introduced in 0.8.2.0 (released in February > 2015). It has become the default implementation for various tools since > 0.9.0.0 (released in October 2015) and it is the only implementation with > suppor

[jira] [Updated] (KAFKA-3330) Decrease log cleaner offset checkpoint if the log is truncated

[ https://issues.apache.org/jira/browse/KAFKA-3330?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-3330: Description: Were getting a number of failures of the log compaction thread with the following error: 2016/0

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

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

[GitHub] kafka pull request: KAFKA-3290: fix race condition with worker tas...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/1008 --- 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-3290: fix race condition with worker tas...

GitHub user hachikuji opened a pull request: https://github.com/apache/kafka/pull/1008 KAFKA-3290: fix race condition with worker task shutdown and mock validation You can merge this pull request into a Git repository by running: $ git pull https://github.com/hachikuji/kafka K

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

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

[VOTE] Deprecating the old Scala producers for 0.10.0.0

Hi all, The new Java producer was introduced in 0.8.2.0 (released in February 2015). It has become the default implementation for various tools since 0.9.0.0 (released in October 2015) and it is the only implementation with support for the security features introduced in 0.9.0.0. Given this, I th

[jira] [Created] (KAFKA-3330) Decrease log cleaner offset checkpoint if the log is truncated

Dong Lin created KAFKA-3330: --- Summary: Decrease log cleaner offset checkpoint if the log is truncated Key: KAFKA-3330 URL: https://issues.apache.org/jira/browse/KAFKA-3330 Project: Kafka Issue Typ

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

See Changes: [junrao] HOTFIX: Include RocksDB dependency in release tarballs -- Started by an SCM change [EnvInject] - Loading node environment variables. Building remotely on ubuntu-us1 (Ubuntu

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

[ 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

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

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

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

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

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

See

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

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

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

[ 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

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

[ 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

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

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-3329) Validation script to test expected behavior of Authorizer implementations

[ 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

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

[ 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-3328) SimpleAclAuthorizer can lose ACLs with frequent add/remove calls

[ 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

[ 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] [Assigned] (KAFKA-3328) SimpleAclAuthorizer can lose ACLs with frequent add/remove calls

[ 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-3325) Out of date instructions in quickstart guide

[ 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] [Resolved] (KAFKA-3325) Out of date instructions in quickstart guide

[ 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

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

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

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

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

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

[ 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

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

[ 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...

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-3323) Negative offsets in Log Segment Index files due to Integer overflow when compaction is enabled

[ 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] [Commented] (KAFKA-3202) Add system test for KIP-31 and KIP-32 - Change message format version on the fly

[ 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

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? ​

Re: Authorizer questions

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-3329) Validation script to test expected behavior of Authorizer implementations

[ 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

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

[ 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] [Updated] (KAFKA-3304) KIP-35 - Retrieving protocol version

[ 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 > -

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

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-3284) Consider removing beta label in security documentation

[ 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 > --

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

[ 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-3304) KIP-35 - Retrieving protocol version

[ 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-2982) Mark the old Scala producer and related classes as deprecated

[ 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-3006) Make collection default container type for sequences in the consumer API

[ 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-3190) KafkaProducer should not invoke callback in send()

[ 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-3283) Consider marking the new consumer as production-ready

[ 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

[ 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-3284) Consider removing beta label in security documentation

[ 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] [Commented] (KAFKA-3006) Make collection default container type for sequences in the consumer API

[ 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-1215) Rack-Aware replica assignment option

[ 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] [Updated] (KAFKA-3006) Make collection default container type for sequences in the consumer API

[ 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-3006) Make collection default container type for sequences in the consumer API

[ 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-3190) KafkaProducer should not invoke callback in send()

[ 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-2658) Implement SASL/PLAIN

[ 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-3283) Consider marking the new consumer as production-ready

[ 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-3201) Add system test for KIP-31 and KIP-32 - Upgrade Test

[ 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-3202) Add system test for KIP-31 and KIP-32 - Change message format version on the fly

[ 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-3188) Add system test for KIP-31 and KIP-32 - Compatibility Test

[ 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-3197) Producer can send message out of order even when in flight request is set to 1.

[ 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-3303) Pass partial record metadata to Interceptor onAcknowledgement in case of errors

[ 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-3314) Add CDDL license to LICENSE and NOTICE file

[ 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-2370) Add pause/unpause connector support

[ 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 > --- >

  1   2   >