[jira] [Commented] (KAFKA-2613) Consider capping `maxParallelForks` for Jenkins builds

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

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

See Changes: [wangguoz] MINOR: putting back kstream stateful transform methods -- [...truncated 3238 lines...] kafka.api.SSLConsumerTest > testSimpleConsumption PASSED

[DISCUSS] KIP-37 - Add namespaces in Kafka

Hey Guys, I just created KIP-37 for adding namespaces to Kafka. KIP-37 tracks the proposal. The idea is to make Kafka support multi-tenancy via namespaces. Feedback and comments are welcome. ​ -- Regards,

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

See

[GitHub] kafka pull request: KAFKA-2613: Make maxParallelForks configurable...

GitHub user ewencp opened a pull request: https://github.com/apache/kafka/pull/293 KAFKA-2613: Make maxParallelForks configurable via Gradle config so it can be turned down on shared build infrastructure. You can merge this pull request into a Git repository by running: $

[jira] [Commented] (KAFKA-658) Implement "Exact Mirroring" functionality in mirror maker

[ https://issues.apache.org/jira/browse/KAFKA-658?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14951388#comment-14951388 ] Justen Walker commented on KAFKA-658: - +1 for Exact Mirroring. I have a use-case where I'd like to

[GitHub] kafka pull request: MINOR: putting back kstream stateful transform...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/292 --- 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] [Updated] (KAFKA-2613) Consider capping `maxParallelForks` for Jenkins builds

[ https://issues.apache.org/jira/browse/KAFKA-2613?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-2613: - Assignee: Ewen Cheslack-Postava Reviewer: Gwen Shapira Status: Patch

[jira] [Created] (KAFKA-2630) Add Namespaces to Kafka

Ashish K Singh created KAFKA-2630: - Summary: Add Namespaces to Kafka Key: KAFKA-2630 URL: https://issues.apache.org/jira/browse/KAFKA-2630 Project: Kafka Issue Type: New Feature

[jira] [Commented] (KAFKA-2629) Enable getting SSL password from an executable rather than passing plaintext password

[ https://issues.apache.org/jira/browse/KAFKA-2629?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14951200#comment-14951200 ] Ashish K Singh commented on KAFKA-2629: --- Thanks for your thoughts [~sriharsha]. I think you raised

[jira] [Commented] (KAFKA-2629) Enable getting SSL password from an executable rather than passing plaintext password

[ https://issues.apache.org/jira/browse/KAFKA-2629?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14951306#comment-14951306 ] Haohui Mai commented on KAFKA-2629: --- While flexibility is generally a good thing, in my opinion the

Re: [VOTE] KIP-31 - Move to relative offsets in compressed message sets.

Thanks a lot for the reply, Jun. Yes, during implementation we can validate the version configurations to make sure they make sense. Since there haven't been objections in a couple of days. I am just closing this KIP with a pass. KIP-31 is passed with four +1(binding), four +1(non binding) and

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

See Changes: [wangguoz] MINOR: typing ProcessorDef [wangguoz] KAFKA-2596: reject commits from unknown groups with positive generations -- [...truncated 164 lines...]

Re: Kafka dotnet SDK suggestion

Hi Ewen, Thanks for your quickest and valuable response. Because i struggled lot to get response for my queries. Some more clarification needed As per my understanding Confluent is Open source and we can use it in our Production environment. Assume we are using confluent. In our project there

[GitHub] kafka pull request: MINOR: typing ProcessorDef

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/289 --- 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-2596) Coordinator should return illegal generation for commits from unknown groups with non-negative generation

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

[GitHub] kafka pull request: KAFKA-2596: reject commits from unknown groups...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/267 --- 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] [Resolved] (KAFKA-2596) Coordinator should return illegal generation for commits from unknown groups with non-negative generation

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

Weird error on machine restart when creating ConsumerConnector reference

Hi, *Following is the consumer related code*: Line#1 > ConsumerConnector consumer = kafka.consumer.Consumer.createJavaConsumerConnector(createConsumerConfig(zkConnect, consumerGroupId, offSetStorage)); private ConsumerConfig createConsumerConfig(String zookeeperConnectString,

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

See Changes: [wangguoz] MINOR: typing ProcessorDef [wangguoz] KAFKA-2596: reject commits from unknown groups with positive generations -- [...truncated 2044 lines...]

[GitHub] kafka pull request: MINOR: putting back kstream stateful transform...

GitHub user ymatsuda opened a pull request: https://github.com/apache/kafka/pull/292 MINOR: putting back kstream stateful transform methods @guozhangwang * added back type safe stateful transform methods (kstream.transform() and kstream.transformValues()) * changed

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

See Changes: [wangguoz] KAFKA-2622: Add Time logical type for Copycat. [wangguoz] KAFKA-2600: Align Kafka Streams' interfaces with Java 8 functional [wangguoz] MINOR: Fix exception message in Copycat's Time logical type.

[jira] [Comment Edited] (KAFKA-2629) Enable getting SSL password from an executable rather than passing plaintext password

[ https://issues.apache.org/jira/browse/KAFKA-2629?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14951306#comment-14951306 ] Haohui Mai edited comment on KAFKA-2629 at 10/9/15 10:40 PM: - While

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

See Changes: [wangguoz] KAFKA-2622: Add Time logical type for Copycat. [wangguoz] KAFKA-2600: Align Kafka Streams' interfaces with Java 8 functional [wangguoz] MINOR: Fix exception message in Copycat's Time logical type.

[jira] [Updated] (KAFKA-2459) Connection backoff/blackout period should start when a connection is disconnected, not when the connection attempt was initiated

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

[jira] [Commented] (KAFKA-2431) Test SSL/TLS impact on performance

[ https://issues.apache.org/jira/browse/KAFKA-2431?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14950641#comment-14950641 ] Ben Stopford commented on KAFKA-2431: - Summary report can be found here:

[jira] [Commented] (KAFKA-2431) Test SSL/TLS impact on performance

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

[jira] [Resolved] (KAFKA-2431) Test SSL/TLS impact on performance

[ https://issues.apache.org/jira/browse/KAFKA-2431?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ben Stopford resolved KAFKA-2431. - Resolution: Done > Test SSL/TLS impact on performance > -- > >

[GitHub] kafka pull request: KAFKA-2431: Easier Testing of SSL

Github user benstopford closed the pull request at: https://github.com/apache/kafka/pull/217 --- 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] [Created] (KAFKA-2627) Kafka Heap Size increase impact performance badly

Mihir Pandya created KAFKA-2627: --- Summary: Kafka Heap Size increase impact performance badly Key: KAFKA-2627 URL: https://issues.apache.org/jira/browse/KAFKA-2627 Project: Kafka Issue Type:

[jira] [Resolved] (KAFKA-2625) Unable to compile scala 2.10 with java 1.6

[ https://issues.apache.org/jira/browse/KAFKA-2625?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma resolved KAFKA-2625. Resolution: Not A Problem As I said, this is expected behaviour, so resolving this as "Not a

[jira] [Created] (KAFKA-2628) KafkaOffsetBackingStoreTest.testGetSet transient test failure

Ewen Cheslack-Postava created KAFKA-2628: Summary: KafkaOffsetBackingStoreTest.testGetSet transient test failure Key: KAFKA-2628 URL: https://issues.apache.org/jira/browse/KAFKA-2628 Project:

Re: Confluent Clarification

Hi Dinesh, You may get a response here, as many members of the confluent team read this list regularly. However, you may want to check the Confluent platform mailing list to see if your question has been answered before. https://groups.google.com/forum/#!forum/confluent-platform Thanks, Grant

Confluent Clarification

Hi All, We are Planning to use Confluent Rest API in our messaging system since we don't find any good Dot Net Client. Is the Kafka and ZooKeeper delivered by Confluent Zip is same as Apache Kafka? Or Changes made in Apache Kafka? Any one please Confirm this? Thanks, Dinesh

[jira] [Commented] (KAFKA-2629) Enable getting SSL password from an executable rather than passing plaintext password

[ https://issues.apache.org/jira/browse/KAFKA-2629?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14950873#comment-14950873 ] Ashish K Singh commented on KAFKA-2629: --- [~junrao], [~gwenshap], [~sriharsha] thoughts? > Enable

[jira] [Work started] (KAFKA-2479) Add CopycatExceptions to indicate transient and permanent errors in a connector/task

[ https://issues.apache.org/jira/browse/KAFKA-2479?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on KAFKA-2479 started by Liquan Pei. - > Add CopycatExceptions to indicate transient and permanent errors in a >

[jira] [Work started] (KAFKA-2484) Add schema projection utilities

[ https://issues.apache.org/jira/browse/KAFKA-2484?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on KAFKA-2484 started by Liquan Pei. - > Add schema projection utilities > --- > >

[jira] [Work started] (KAFKA-2480) Handle non-CopycatExceptions from SinkTasks

[ https://issues.apache.org/jira/browse/KAFKA-2480?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on KAFKA-2480 started by Liquan Pei. - > Handle non-CopycatExceptions from SinkTasks >

[jira] [Commented] (KAFKA-2629) Enable getting SSL password from an executable rather than passing plaintext password

[ https://issues.apache.org/jira/browse/KAFKA-2629?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14950932#comment-14950932 ] Sriharsha Chintalapani commented on KAFKA-2629: --- [~singhashish] The distribution of

[jira] [Created] (KAFKA-2629) Enable getting SSL password from an executable rather than passing plaintext password

Ashish K Singh created KAFKA-2629: - Summary: Enable getting SSL password from an executable rather than passing plaintext password Key: KAFKA-2629 URL: https://issues.apache.org/jira/browse/KAFKA-2629

[jira] [Assigned] (KAFKA-2369) Add Copycat REST API

[ https://issues.apache.org/jira/browse/KAFKA-2369?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Liquan Pei reassigned KAFKA-2369: - Assignee: Liquan Pei (was: Ewen Cheslack-Postava) > Add Copycat REST API >

[jira] [Comment Edited] (KAFKA-2629) Enable getting SSL password from an executable rather than passing plaintext password

[ https://issues.apache.org/jira/browse/KAFKA-2629?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14950932#comment-14950932 ] Sriharsha Chintalapani edited comment on KAFKA-2629 at 10/9/15 6:30 PM:

[GitHub] kafka pull request: KAFKA-2622: Add Time logical type for Copycat.

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/285 --- 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-2622) Add Time logical type for Copycat

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

[jira] [Updated] (KAFKA-2622) Add Time logical type for Copycat

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

[jira] [Updated] (KAFKA-2615) Poll() method is broken wrt time

[ https://issues.apache.org/jira/browse/KAFKA-2615?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Eno Thereska updated KAFKA-2615: Labels: patch (was: ) Reviewer: Guozhang Wang Fix Version/s: 0.8.2.1

[jira] [Updated] (KAFKA-1843) Metadata fetch/refresh in new producer should handle all node connection states gracefully

[ https://issues.apache.org/jira/browse/KAFKA-1843?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Eno Thereska updated KAFKA-1843: Labels: patch (was: ) Reviewer: Guozhang Wang Fix Version/s: 0.8.2.1

[GitHub] kafka pull request: KAFKA-2600 Align Kafka Streams' interfaces wit...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/270 --- 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-2600) Make KStream interfaces compatible with Java 8 java.util.function

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

[jira] [Updated] (KAFKA-2600) Make KStream interfaces compatible with Java 8 java.util.function

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

[GitHub] kafka pull request: MINOR: Fix exception message in Copycat's Time...

GitHub user ewencp opened a pull request: https://github.com/apache/kafka/pull/291 MINOR: Fix exception message in Copycat's Time logical type. You can merge this pull request into a Git repository by running: $ git pull https://github.com/ewencp/kafka fixup-time-logical-type

[GitHub] kafka pull request: MINOR: Fix exception message in Copycat's Time...

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