[jira] [Commented] (KAFKA-4065) Property missing in ProcuderConfig.java - KafkaProducer API 0.9.0.0

[ https://issues.apache.org/jira/browse/KAFKA-4065?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15436313#comment-15436313 ] manzar commented on KAFKA-4065: --- If "compressed.topics" is removed then how we can enable compression for

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

See Changes: [ismael] MINOR: Update rocksDB dependency to 4.9.0 [ismael] MINOR: Fix wording in Metadata.add javadoc -- [...truncated 12126 lines...]

Re: [DISCUSS] Time-based releases for Apache Kafka

Hi Team Kafka, As per the KIP meeting, I created a wiki: https://cwiki.apache.org/confluence/display/KAFKA/Time+Based+Release+Plan Summarizing most of the discussion so far. Comments and additional discussion is welcome :) Gwen On Wed, Aug 17, 2016 at 12:31 PM, Vahid S Hashemian

[jira] [Issue Comment Deleted] (KAFKA-4065) Property missing in ProcuderConfig.java - KafkaProducer API 0.9.0.0

[ https://issues.apache.org/jira/browse/KAFKA-4065?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] manzar updated KAFKA-4065: -- Comment: was deleted (was: If "compressed.topics" is removed then how we can enable compression for some

[jira] [Commented] (KAFKA-4065) Property missing in ProcuderConfig.java - KafkaProducer API 0.9.0.0

[ https://issues.apache.org/jira/browse/KAFKA-4065?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15436295#comment-15436295 ] manzar commented on KAFKA-4065: --- If "compressed.topics" is removed then how we can enable compression for

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

See

[DISCUSS] Remove beta label from the new Java consumer

Hi all, We currently say the following in our documentation: "As of the 0.9.0 release we have added a new Java consumer to replace our existing high-level ZooKeeper-based consumer and low-level consumer APIs. This client is considered beta quality."[1] Since then, Jason and the community have

[GitHub] kafka pull request #1719: Sentences are not fluent

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

[GitHub] kafka pull request #1783: MINOR: Update rocksDB dependency to 4.9.0

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

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

See -- [...truncated 10776 lines...] org.apache.kafka.clients.consumer.KafkaConsumerTest > testCommitsFetchedDuringAssign STARTED org.apache.kafka.clients.consumer.KafkaConsumerTest >

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

See -- [...truncated 6771 lines...] kafka.coordinator.GroupMetadataManagerTest > testStoreNonEmptyGroup STARTED kafka.coordinator.GroupMetadataManagerTest > testStoreNonEmptyGroup PASSED

[jira] [Commented] (KAFKA-3846) Connect record types should include timestamps

[ https://issues.apache.org/jira/browse/KAFKA-3846?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15435918#comment-15435918 ] Ewen Cheslack-Postava commented on KAFKA-3846: -- [~michael.andre.pearce] Since the timestamp

[jira] [Created] (KAFKA-4086) long processing consumer restart will stall

Dale Jin created KAFKA-4086: --- Summary: long processing consumer restart will stall Key: KAFKA-4086 URL: https://issues.apache.org/jira/browse/KAFKA-4086 Project: Kafka Issue Type: Bug

Jenkins build is back to normal : kafka-0.10.0-jdk7 #195

See

[GitHub] kafka pull request #1783: MINOR: Update rocksDB dependency to 4.9.0

GitHub user mfenniak opened a pull request: https://github.com/apache/kafka/pull/1783 MINOR: Update rocksDB dependency to 4.9.0 rocksdbjni version 4.9.0 now includes support for running on Windows; this PR updates Kafka Stream's dependency to that version. Tests pass locally,

[jira] [Commented] (KAFKA-3846) Connect record types should include timestamps

[ https://issues.apache.org/jira/browse/KAFKA-3846?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15435842#comment-15435842 ] Michael Andre Pearce (IG) commented on KAFKA-3846: -- This looks great, is any documents

Re: [DISCUSS] KIP-76: Enable getting password from executable rather than passing as plaintext in config files

+1 (non-binding) Thanks, Bharat On Wed, Aug 24, 2016 at 12:03 PM, Ashish Singh wrote: > Hey Guys, > > I’ve just posted KIP-76: Enable getting password from executable rather > than passing as plaintext in config files >

[jira] [Created] (KAFKA-4085) Create Consumer fetch(..) implementation that returns any events available at time of request

Josh Goodrich created KAFKA-4085: Summary: Create Consumer fetch(..) implementation that returns any events available at time of request Key: KAFKA-4085 URL: https://issues.apache.org/jira/browse/KAFKA-4085

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

See -- Started by user ijuma [EnvInject] - Loading node environment variables. Building remotely on ubuntu-us1 (Ubuntu golang-ppa ubuntu-us ubuntu) in workspace

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

See -- Started by user ijuma [EnvInject] - Loading node environment variables. Building remotely on ubuntu-us1 (Ubuntu golang-ppa ubuntu-us ubuntu) in workspace

[jira] [Commented] (KAFKA-4082) Support Gradle 3.0

[ https://issues.apache.org/jira/browse/KAFKA-4082?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15435634#comment-15435634 ] ASF GitHub Bot commented on KAFKA-4082: --- Github user ijuma closed the pull request at:

[GitHub] kafka pull request #1781: KAFKA-4082; Support usage of Gradle 3.0 for bootst...

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

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

See -- Started by an SCM change [EnvInject] - Loading node environment variables. Building remotely on ubuntu-us1 (Ubuntu golang-ppa ubuntu-us ubuntu) in workspace

[jira] [Updated] (KAFKA-4082) Support Gradle 3.0

[ https://issues.apache.org/jira/browse/KAFKA-4082?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-4082: - Fix Version/s: 0.10.0.2 > Support Gradle 3.0 > -- > >

[DISCUSS] KIP-76: Enable getting password from executable rather than passing as plaintext in config files

Hey Guys, I’ve just posted KIP-76: Enable getting password from executable rather than passing as plaintext in config files . The proposal is to

Re: Jenkins issues?

Sorry, I think I found the right URL: https://issues.apache.org/jira/issues/?filter=12335405=project%20%3D%20INFRA%20AND%20text%20~%20%22kafka%22%20ORDER%20BY%20updated%20DESC%2C%20createdDate%20DESC Will try to open a ticket. --Vahid From: Vahid S Hashemian/Silicon Valley/IBM@IBMUS To:

Re: Jenkins issues?

Thanks Ismael. :) I'd like to help, but not sure about the steps. Is this where the ticket is opened: https://issues.jenkins-ci.org/projects/INFRA/issues/INFRA-633?filter=allopenissues And I probably need to create an account there. --Vahid From: Ismael Juma To:

Re: [VOTE] KIP-47 - Add timestamp-based log deletion policy

Hello Guozhang, KIP-71 seems unrelated to this KIP. KIP-47 is just adding a new deletion policy (minimum timestamp), while KIP-71 is allowing deletion and compaction to coexist. They both will touch LogManager, but the change for KIP-47 is very isolated. On Wed, Aug 24, 2016 at 2:21 PM

Re: Jenkins issues?

Some builds failed due to disk space issues. We should file an INFRA ticket to let them know. If you want to help, that would be great. :) Ismael On Wed, Aug 24, 2016 at 7:15 PM, Vahid S Hashemian < vahidhashem...@us.ibm.com> wrote: > Is there a known issue with Jenkins? > Almost all recent

Re: [VOTE] KIP-47 - Add timestamp-based log deletion policy

Hi Bill, I would like to reason if there is any correlation between this KIP and KIP-71 https://cwiki.apache.org/confluence/display/KAFKA/KIP-71%3A+Enable+log+compaction+and+deletion+to+co-exist I feel they are orthogonal but would like to double check with you. Guozhang On Wed, Aug 24,

Jenkins issues?

Is there a known issue with Jenkins? Almost all recent builds have failed. --Vahid

Re: [VOTE] KIP-47 - Add timestamp-based log deletion policy

I'd like to re-awaken this voting thread now that KIP-33 has merged. This KIP is now completely unblocked. I have a working branch off of trunk with my proposed fix, including testing. On Mon, May 9, 2016 at 8:30 PM Guozhang Wang wrote: > Jay, Bill: > > I'm thinking of one

[jira] [Assigned] (KAFKA-4074) Deleting a topic can make it unavailable even if delete.topic.enable is false

[ https://issues.apache.org/jira/browse/KAFKA-4074?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar Reddy reassigned KAFKA-4074: -- Assignee: Manikumar Reddy > Deleting a topic can make it unavailable even if

[jira] [Commented] (KAFKA-4084) automated leader rebalance causes replication downtime for clusters with too many partitions

[ https://issues.apache.org/jira/browse/KAFKA-4084?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15435073#comment-15435073 ] Jun Rao commented on KAFKA-4084: [~tcrayford-heroku], if you check

Re: [DISCUSS] KIP-63: Unify store and downstream caching in streams

Hi folks, We've been working on a proof-of-concept for KIP-63 and that can now be found at the main JIRA (https://issues.apache.org/jira/browse/KAFKA-3776) under PR https://github.com/apache/kafka/pull/1752. It is still work in progress, however we are confident that the basic structure is there.

[jira] [Created] (KAFKA-4084) automated leader rebalance causes replication downtime for clusters with too many partitions

Tom Crayford created KAFKA-4084: --- Summary: automated leader rebalance causes replication downtime for clusters with too many partitions Key: KAFKA-4084 URL: https://issues.apache.org/jira/browse/KAFKA-4084

[GitHub] kafka pull request #1782: MINOR: Fix ProcessorTopologyTestDriver to support ...

GitHub user mfenniak opened a pull request: https://github.com/apache/kafka/pull/1782 MINOR: Fix ProcessorTopologyTestDriver to support multiple source topics There's a minor bug in ProcessorTopologyTestDriver that prevents it from working with a topology that contains multiple

[jira] [Commented] (KAFKA-4082) Support Gradle 3.0

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

[GitHub] kafka pull request #1781: KAFKA-4082; Support usage of Gradle 3.0 for bootst...

GitHub user ijuma opened a pull request: https://github.com/apache/kafka/pull/1781 KAFKA-4082; Support usage of Gradle 3.0 for bootstrapping gradlew The main requirement is to remove the usage of `useAnt` and we need to upgrade scoverage because the older version refers to

[jira] [Assigned] (KAFKA-3778) Avoiding using range queries of RocksDBWindowStore on KStream windowed aggregations

[ https://issues.apache.org/jira/browse/KAFKA-3778?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Eno Thereska reassigned KAFKA-3778: --- Assignee: Eno Thereska > Avoiding using range queries of RocksDBWindowStore on KStream

[jira] [Work started] (KAFKA-3778) Avoiding using range queries of RocksDBWindowStore on KStream windowed aggregations

[ https://issues.apache.org/jira/browse/KAFKA-3778?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on KAFKA-3778 started by Eno Thereska. --- > Avoiding using range queries of RocksDBWindowStore on KStream windowed >

[GitHub] kafka pull request #1780: Kafka 4077: Backdate system test certificates to c...

GitHub user rajinisivaram opened a pull request: https://github.com/apache/kafka/pull/1780 Kafka 4077: Backdate system test certificates to cope with clock skew You can merge this pull request into a Git repository by running: $ git pull https://github.com/rajinisivaram/kafka

[jira] [Work started] (KAFKA-4083) ReassignPartitionsCommand does not check replication factor

[ https://issues.apache.org/jira/browse/KAFKA-4083?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on KAFKA-4083 started by Simon Wan Wenli. -- > ReassignPartitionsCommand does not check replication factor >

[jira] [Updated] (KAFKA-4083) ReassignPartitionsCommand does not check replication factor

[ https://issues.apache.org/jira/browse/KAFKA-4083?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Simon Wan Wenli updated KAFKA-4083: --- Status: Patch Available (was: In Progress) > ReassignPartitionsCommand does not check

[jira] [Updated] (KAFKA-4083) ReassignPartitionsCommand does not check replication factor

[ https://issues.apache.org/jira/browse/KAFKA-4083?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Simon Wan Wenli updated KAFKA-4083: --- Description: ReassignPartitionsCommand does not check whether the replication factor of a

[GitHub] kafka pull request #1779: fix different replication factor during replica re...

GitHub user swwl1992 opened a pull request: https://github.com/apache/kafka/pull/1779 fix different replication factor during replica reassignment You can merge this pull request into a Git repository by running: $ git pull https://github.com/swwl1992/kafka

[jira] [Commented] (KAFKA-4042) DistributedHerder thread can die because of connector & task lifecycle exceptions

[ https://issues.apache.org/jira/browse/KAFKA-4042?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15434411#comment-15434411 ] ASF GitHub Bot commented on KAFKA-4042: --- Github user shikhar closed the pull request at:

[GitHub] kafka pull request #1745: KAFKA-4042: prevent DistributedHerder thread from ...

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

[jira] [Commented] (KAFKA-4042) DistributedHerder thread can die because of connector & task lifecycle exceptions

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

[GitHub] kafka pull request #1778: KAFKA-4042: Contain connector & task start/stop fa...

GitHub user shikhar opened a pull request: https://github.com/apache/kafka/pull/1778 KAFKA-4042: Contain connector & task start/stop failures within the Worker Invoke the statusListener.onFailure() callback on start failures so that the statusBackingStore is updated. This involved

[jira] [Updated] (KAFKA-4083) ReassignPartitionsCommand does not check replication factor

[ https://issues.apache.org/jira/browse/KAFKA-4083?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Simon Wan Wenli updated KAFKA-4083: --- Environment: Linux 14.04 LTS, Scala 2.10 (was: Linux 14.04 LTS) > ReassignPartitionsCommand

[jira] [Created] (KAFKA-4083) ReassignPartitionsCommand does not check replication factor

Simon Wan Wenli created KAFKA-4083: -- Summary: ReassignPartitionsCommand does not check replication factor Key: KAFKA-4083 URL: https://issues.apache.org/jira/browse/KAFKA-4083 Project: Kafka