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

[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

[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

[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

[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

[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

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

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.

[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

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

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

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

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

[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

[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

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

[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

[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

[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

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

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

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

See

[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

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

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

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

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

See

[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

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

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

[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

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

<    1   2