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

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

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 kafka.integration.Primitiv

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

See

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

[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&focusedCommentId=14951391#comment-14951391 ] ASF GitHub Bot commented on KAFKA-2613: --- GitHub user ewencp opened a pull request:

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

[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&focusedCommentId=14951388#comment-14951388 ] Justen Walker commented on KAFKA-658: - +1 for Exact Mirroring. I have a use-case where

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

[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&focusedCommentId=14951306#comment-14951306 ] Haohui Mai edited comment on KAFKA-2629 at 10/9/15 10:40 PM: -

[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&focusedCommentId=14951306#comment-14951306 ] Haohui Mai commented on KAFKA-2629: --- While flexibility is generally a good thing, in my

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

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] [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&focusedCommentId=14951200#comment-14951200 ] Ashish K Singh commented on KAFKA-2629: --- Thanks for your thoughts [~sriharsha]. I th

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

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

[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

[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

[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&focusedCommentId=14951036#comment-14951036 ] ASF GitHub Bot commented on KAFKA-2600: --- Github user asfgit closed the pull request

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

[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

[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-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] [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&focusedCommentId=14950995#comment-14950995 ] ASF GitHub Bot commented on KAFKA-2622: --- Github user asfgit closed the pull request

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

[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&focusedCommentId=14950932#comment-14950932 ] Sriharsha Chintalapani edited comment on KAFKA-2629 at 10/9/15 6:30 PM:

[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&focusedCommentId=14950932#comment-14950932 ] Sriharsha Chintalapani commented on KAFKA-2629: --- [~singhashish] The distribu

[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] [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 > connector/ta

[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] [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] [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&focusedCommentId=14950873#comment-14950873 ] Ashish K Singh commented on KAFKA-2629: --- [~junrao], [~gwenshap], [~sriharsha] though

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

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

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

[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&focusedCommentId=14950644#comment-14950644 ] ASF GitHub Bot commented on KAFKA-2431: --- Github user benstopford closed the pull req

[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] [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&focusedCommentId=14950641#comment-14950641 ] Ben Stopford commented on KAFKA-2431: - Summary report can be found here: https://docs

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

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

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...] kafka.api.ConsumerBounceTe

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 a