[jira] [Commented] (KAFKA-2079) Support exhibitor

[ https://issues.apache.org/jira/browse/KAFKA-2079?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14907723#comment-14907723 ] Joe Stein commented on KAFKA-2079: -- Not yet, I started a KIP for it https://cwiki.apache

[jira] [Commented] (KAFKA-2417) Ducktape tests for SSL/TLS

[ https://issues.apache.org/jira/browse/KAFKA-2417?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14907763#comment-14907763 ] Rajini Sivaram commented on KAFKA-2417: --- [~ijuma] [~granders] Thank you, yes, I can

[jira] [Created] (KAFKA-2581) Run all existing ducktape tests with SSL-enabled clients and brokers

Rajini Sivaram created KAFKA-2581: - Summary: Run all existing ducktape tests with SSL-enabled clients and brokers Key: KAFKA-2581 URL: https://issues.apache.org/jira/browse/KAFKA-2581 Project: Kafka

[jira] [Commented] (KAFKA-2417) Ducktape tests for SSL/TLS

[ https://issues.apache.org/jira/browse/KAFKA-2417?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14907814#comment-14907814 ] Ismael Juma commented on KAFKA-2417: Perfect, thanks. > Ducktape tests for SSL/TLS >

[jira] [Updated] (KAFKA-1695) Authenticate connection to Zookeeper

[ https://issues.apache.org/jira/browse/KAFKA-1695?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-1695: --- Status: In Progress (was: Patch Available) Setting this to in-progress because it doesn't include tes

[GitHub] kafka pull request: KAFKA-2562: update kafka scripts to use new to...

GitHub user omkreddy opened a pull request: https://github.com/apache/kafka/pull/242 KAFKA-2562: update kafka scripts to use new tools/code Updated kafka-producer-perf-test.sh to use org.apache.kafka.clients.tools.ProducerPerformance. Updated build.gradle to add kafka-tools-0.

[jira] [Commented] (KAFKA-2562) check Kafka scripts for 0.9.0.0

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

[jira] [Assigned] (KAFKA-2562) check Kafka scripts for 0.9.0.0

[ https://issues.apache.org/jira/browse/KAFKA-2562?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar Reddy reassigned KAFKA-2562: -- Assignee: Manikumar Reddy > check Kafka scripts for 0.9.0.0 > -

[jira] [Updated] (KAFKA-2562) check Kafka scripts for 0.9.0.0

[ https://issues.apache.org/jira/browse/KAFKA-2562?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar Reddy updated KAFKA-2562: --- Status: Patch Available (was: Open) > check Kafka scripts for 0.9.0.0 > -

Re: [ANNOUNCE] New Committer Sriharsha Chintalapani

Congratulations, Harsha! :-) -Michael > On 22 Sep 2015, at 06:10, Jun Rao wrote: > > I am pleased to announce that the Apache Kafka PMC has voted to > invite Sriharsha Chintalapani as a committer and Sriharsha has accepted. > > Sriharsha has contributed numerous patches to Kafka. The most si

Wiki edit permissions.

Hi, Can I get edit permissions for the wiki please? Just wanting to correct the duplicate ‘log.cleaner.min.cleanable.ratio‘ config setting at the bottom of https://cwiki.apache.org/confluence/display/KAFKA/Log+Compaction Username: bigandy Thanks, Andy

[jira] [Assigned] (KAFKA-2409) Have KafkaConsumer.committed() return null when there is no committed offset

[ https://issues.apache.org/jira/browse/KAFKA-2409?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson reassigned KAFKA-2409: -- Assignee: Jason Gustafson (was: Sreepathi Prasanna) > Have KafkaConsumer.committed() r

Re: Wiki edit permissions.

Andy, What is your apache id? Guozhang On Fri, Sep 25, 2015 at 6:44 AM, Andrew Coates wrote: > Hi, > > Can I get edit permissions for the wiki please? > > Just wanting to correct the duplicate ‘log.cleaner.min.cleanable.ratio‘ > config > setting at the bottom of > https://cwiki.apache.org/conf

[jira] [Commented] (KAFKA-106) Include rolledup segment size stats via jmx

[ https://issues.apache.org/jira/browse/KAFKA-106?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14908263#comment-14908263 ] Jun Rao commented on KAFKA-106: --- [~utkarshcmu], just added you to the contributor list and yo

[jira] [Commented] (KAFKA-2580) Kafka Broker keeps file handles open for all log files (even if its not written to/read from)

[ https://issues.apache.org/jira/browse/KAFKA-2580?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14908298#comment-14908298 ] Vinoth Chandar commented on KAFKA-2580: --- More context on how we determined this {co

[jira] [Commented] (KAFKA-2409) Have KafkaConsumer.committed() return null when there is no committed offset

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

[GitHub] kafka pull request: KAFKA-2409; have KafkaConsumer.committed retur...

GitHub user hachikuji opened a pull request: https://github.com/apache/kafka/pull/243 KAFKA-2409; have KafkaConsumer.committed return null when there is no commit You can merge this pull request into a Git repository by running: $ git pull https://github.com/hachikuji/kafka KA

[jira] [Assigned] (KAFKA-106) Include rolledup segment size stats via jmx

[ https://issues.apache.org/jira/browse/KAFKA-106?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] UTKARSH BHATNAGAR reassigned KAFKA-106: --- Assignee: UTKARSH BHATNAGAR > Include rolledup segment size stats via jmx > --

[jira] [Comment Edited] (KAFKA-2079) Support exhibitor

[ https://issues.apache.org/jira/browse/KAFKA-2079?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14908324#comment-14908324 ] Helena Edelson edited comment on KAFKA-2079 at 9/25/15 4:59 PM:

[jira] [Commented] (KAFKA-2079) Support exhibitor

[ https://issues.apache.org/jira/browse/KAFKA-2079?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14908324#comment-14908324 ] Helena Edelson commented on KAFKA-2079: --- [~joestein] Thanks. +1 and Low handing fr

Release plan for kafka security

Hello Kafka Developers, I’m looking for a queuing solution and Kafka is very near the top of my list … except that security is a primary concern (see the domain my email is coming from ;-) I’m a little confused about when security is going to be part of Kafka and in what release. On the Future

Re: Release plan for kafka security

Basically, 0.8.3 has been renamed to 0.9.0. The plan is to include security in the 0.9 release which should happen once all the blocker bugs have been resolved and testing is complete (committers can provide more accurate timelines). On Fri, Sep 25, 2015 at 10:35 AM, Whitney, Adam wrote: > Hello

[jira] [Commented] (KAFKA-2409) Have KafkaConsumer.committed() return null when there is no committed offset

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

[GitHub] kafka pull request: KAFKA-2409; have KafkaConsumer.committed retur...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/243 --- 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] [Resolved] (KAFKA-2409) Have KafkaConsumer.committed() return null when there is no committed offset

[ https://issues.apache.org/jira/browse/KAFKA-2409?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-2409. -- Resolution: Fixed Issue resolved by pull request 243 [https://github.com/apache/kafka/pull/243]

Re: [VOTE] KIP-28 - Add a processor client for stream data processing

The voting period has ended, and the results: binding +1: 3 non-binding +1: 5 binding -1: 0 The vote has passed and I will mark this KIP as adopted. Thanks everyone for involving in this long discussion and voting process. Guozhang On Tue, Sep 22, 2015 at 12:26 PM, Edward Ribeiro wrote: > +1

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

+1. I agree that it's worth thinking through the migration plan a bit more. Thanks, Jun On Thu, Sep 24, 2015 at 6:14 PM, Joel Koshy wrote: > +1 on everything but the upgrade plan, which is a bit scary - will > comment on the discuss thread. > > On Thu, Sep 24, 2015 at 9:51 AM, Mayuresh Gharat

[jira] [Created] (KAFKA-2582) ConsumerMetdata authorization error not returned to user

Jason Gustafson created KAFKA-2582: -- Summary: ConsumerMetdata authorization error not returned to user Key: KAFKA-2582 URL: https://issues.apache.org/jira/browse/KAFKA-2582 Project: Kafka Is

Re: [DISCUSS] KIP-31 - Message format change proposal

Hey Becket, I do think we need the interim deployment phase, set message.format.version and down-convert for producer request v2. Down-conversion for v2 is no worse than what the broker is doing now. I don't think we want a prolonged phase where we down-convert for every v1 fetch - in fact I'm les

[jira] [Commented] (KAFKA-1215) Rack-Aware replica assignment option

[ https://issues.apache.org/jira/browse/KAFKA-1215?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14908460#comment-14908460 ] Aditya Auradkar commented on KAFKA-1215: [~allenxwang] - bump. > Rack-Aware repl

Jenkins build is back to normal : Kafka-trunk #638

See

[GitHub] kafka pull request: KAFKA-2555: Infinite recursive function call w...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/221 --- 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] [Resolved] (KAFKA-2555) Infinite recursive function call occurs when ConsumerRebalanceCallback.onPartitionRevoked() calls commitSync()

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

[jira] [Commented] (KAFKA-2555) Infinite recursive function call occurs when ConsumerRebalanceCallback.onPartitionRevoked() calls commitSync()

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

Build failed in Jenkins: Kafka-trunk #639

See Changes: [wangguoz] KAFKA-2555: Fix infinite recursive ensurePartitionAssignment in callback's commitSync -- Started by an SCM change [EnvInject] - Loading node environment variables. Building re

[jira] [Commented] (KAFKA-2189) Snappy compression of message batches less efficient in 0.8.2.1

[ https://issues.apache.org/jira/browse/KAFKA-2189?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14908553#comment-14908553 ] Jordan Shaw commented on KAFKA-2189: Hi all, I was wondering if this affects only 0.8.

Re: Release plan for kafka security

My guess is that we might be able to get security and consumer work in by November for the 0.9 release. On Fri, Sep 25, 2015 at 10:44 AM, Aditya Auradkar < aaurad...@linkedin.com.invalid> wrote: > Basically, 0.8.3 has been renamed to 0.9.0. The plan is to include security > in the 0.9 release whi

[GitHub] kafka pull request: HOTFIX: remove unused import causing checkstyl...

GitHub user hachikuji opened a pull request: https://github.com/apache/kafka/pull/244 HOTFIX: remove unused import causing checkstyle to fail You can merge this pull request into a Git repository by running: $ git pull https://github.com/hachikuji/kafka hotfix-checkstyle Alte

[GitHub] kafka pull request: HOTFIX: remove unused import causing checkstyl...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/244 --- 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] [Created] (KAFKA-2583) Log compaction documentation incorrect

Ben Nham created KAFKA-2583: --- Summary: Log compaction documentation incorrect Key: KAFKA-2583 URL: https://issues.apache.org/jira/browse/KAFKA-2583 Project: Kafka Issue Type: Bug Componen

[jira] [Updated] (KAFKA-2583) Log compaction documentation incorrect

[ https://issues.apache.org/jira/browse/KAFKA-2583?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ben Nham updated KAFKA-2583: Description: This page claims that log.cleanup.policy can be one of "delete" or "dedupe": https://cwiki.apa

[jira] [Commented] (KAFKA-2583) Log compaction documentation incorrect

[ https://issues.apache.org/jira/browse/KAFKA-2583?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14908701#comment-14908701 ] Grant Henke commented on KAFKA-2583: I agree that we should be consistent and even pot

[GitHub] kafka pull request: KAFKA-2582; ConsumerMetdata authorization erro...

GitHub user hachikuji opened a pull request: https://github.com/apache/kafka/pull/245 KAFKA-2582; ConsumerMetdata authorization error not returned to user You can merge this pull request into a Git repository by running: $ git pull https://github.com/hachikuji/kafka KAFKA-2582

Build failed in Jenkins: Kafka-trunk #640

See Changes: [wangguoz] HOTFIX: remove unused import causing checkstyle to fail -- [...truncated 5584 lines...] kafka.log.OffsetMapTest > testClear PASSED kafka.log.LogTest > testAppendAndReadWithNon

[jira] [Commented] (KAFKA-2582) ConsumerMetdata authorization error not returned to user

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

[DISCUSS] KIP-35 - Retrieve protocol version

Good evening, KIP-35 was created to address current and future broker-client compatibility. https://cwiki.apache.org/confluence/display/KAFKA/KIP-35+-+Retrieving+protocol+version Summary: * allow clients to retrieve the broker's protocol version * make broker handle unknown protocol requests g

[jira] [Commented] (KAFKA-2189) Snappy compression of message batches less efficient in 0.8.2.1

[ https://issues.apache.org/jira/browse/KAFKA-2189?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14908770#comment-14908770 ] Jun Rao commented on KAFKA-2189: 0.8.2.0 has the same problem since it depends on snappy-j

[GitHub] kafka pull request: KAFKA-2582; ConsumerMetdata authorization erro...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/245 --- 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-2582) ConsumerMetdata authorization error not returned to user

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

[jira] [Resolved] (KAFKA-2582) ConsumerMetdata authorization error not returned to user

[ https://issues.apache.org/jira/browse/KAFKA-2582?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao resolved KAFKA-2582. Resolution: Fixed Fix Version/s: 0.9.0.0 > ConsumerMetdata authorization error not returned to user >

[jira] [Commented] (KAFKA-2374) Implement Copycat log/file connector

[ https://issues.apache.org/jira/browse/KAFKA-2374?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14908849#comment-14908849 ] Ewen Cheslack-Postava commented on KAFKA-2374: -- @gwenshap Was looking through

[jira] [Commented] (KAFKA-2368) Add Copycat standalone CLI

[ https://issues.apache.org/jira/browse/KAFKA-2368?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14908850#comment-14908850 ] Ewen Cheslack-Postava commented on KAFKA-2368: -- Right now this interface is e

[jira] [Commented] (KAFKA-2448) BrokerChangeListener missed broker id path ephemeral node deletion event.

[ https://issues.apache.org/jira/browse/KAFKA-2448?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14908857#comment-14908857 ] Jun Rao commented on KAFKA-2448: [~becket_qin], since ZK watchers are one-time watchers, c

[jira] [Created] (KAFKA-2584) SecurityProtocol enum validation should be removed or relaxed for non-config usages

Joel Koshy created KAFKA-2584: - Summary: SecurityProtocol enum validation should be removed or relaxed for non-config usages Key: KAFKA-2584 URL: https://issues.apache.org/jira/browse/KAFKA-2584 Project:

[GitHub] kafka pull request: MINOR: Fix Vagrant setup script for use on Fed...

GitHub user lindong28 opened a pull request: https://github.com/apache/kafka/pull/246 MINOR: Fix Vagrant setup script for use on Fedora I tested and verified that `vagrant --version | egrep -o "\d+\.\d+\.\d+"` works on Mac but failed on RedHad 6.4, while `vagrant --version | egrep -

[jira] [Commented] (KAFKA-2581) Run all existing ducktape tests with SSL-enabled clients and brokers

[ https://issues.apache.org/jira/browse/KAFKA-2581?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14908871#comment-14908871 ] Ewen Cheslack-Postava commented on KAFKA-2581: -- Can we clarify the scope of t

[jira] [Commented] (KAFKA-2581) Run all existing ducktape tests with SSL-enabled clients and brokers

[ https://issues.apache.org/jira/browse/KAFKA-2581?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14908875#comment-14908875 ] Ismael Juma commented on KAFKA-2581: Hi [~ewencp], why don't you think replication_tes

Build failed in Jenkins: Kafka-trunk #641

See Changes: [junrao] KAFKA-2582; ConsumerMetdata authorization error not returned to user -- [...truncated 5594 lines...] kafka.zk.ZKPathTest > testCreatePersistentPathThrowsException PASSED kafka.z

[jira] [Commented] (KAFKA-2581) Run all existing ducktape tests with SSL-enabled clients and brokers

[ https://issues.apache.org/jira/browse/KAFKA-2581?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14908890#comment-14908890 ] Ewen Cheslack-Postava commented on KAFKA-2581: -- [~ijuma] We should absolutely

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

+1 -Ewen On Fri, Sep 25, 2015 at 11:15 AM, Jun Rao wrote: > +1. I agree that it's worth thinking through the migration plan a bit more. > > Thanks, > > Jun > > On Thu, Sep 24, 2015 at 6:14 PM, Joel Koshy wrote: > > > +1 on everything but the upgrade plan, which is a bit scary - will > > commen

[jira] [Commented] (KAFKA-2374) Implement Copycat log/file connector

[ https://issues.apache.org/jira/browse/KAFKA-2374?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14908897#comment-14908897 ] Gwen Shapira commented on KAFKA-2374: - Good question. I am in favor of keeping Kafka

[jira] [Comment Edited] (KAFKA-2581) Run all existing ducktape tests with SSL-enabled clients and brokers

[ https://issues.apache.org/jira/browse/KAFKA-2581?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14908902#comment-14908902 ] Ismael Juma edited comment on KAFKA-2581 at 9/25/15 11:53 PM: --

[jira] [Commented] (KAFKA-2581) Run all existing ducktape tests with SSL-enabled clients and brokers

[ https://issues.apache.org/jira/browse/KAFKA-2581?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14908902#comment-14908902 ] Ismael Juma commented on KAFKA-2581: Yes, SSL can certainly introduce new failure scen

[jira] [Commented] (KAFKA-2580) Kafka Broker keeps file handles open for all log files (even if its not written to/read from)

[ https://issues.apache.org/jira/browse/KAFKA-2580?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14908905#comment-14908905 ] Guozhang Wang commented on KAFKA-2580: -- Hey [~vinothchandar], could you let me know t

[jira] [Comment Edited] (KAFKA-2580) Kafka Broker keeps file handles open for all log files (even if its not written to/read from)

[ https://issues.apache.org/jira/browse/KAFKA-2580?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14908905#comment-14908905 ] Guozhang Wang edited comment on KAFKA-2580 at 9/25/15 11:56 PM:

[jira] [Comment Edited] (KAFKA-2480) Handle non-CopycatExceptions from SinkTasks

[ https://issues.apache.org/jira/browse/KAFKA-2480?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14908909#comment-14908909 ] Liquan Pei edited comment on KAFKA-2480 at 9/26/15 12:00 AM: -

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

[ https://issues.apache.org/jira/browse/KAFKA-2480?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14908909#comment-14908909 ] Liquan Pei commented on KAFKA-2480: --- Can you assign this to me? > Handle non-CopycatExc

[jira] [Commented] (KAFKA-2580) Kafka Broker keeps file handles open for all log files (even if its not written to/read from)

[ https://issues.apache.org/jira/browse/KAFKA-2580?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14908910#comment-14908910 ] Vinoth Chandar commented on KAFKA-2580: --- Thanks for jumping in [~guozhang] .we have

[GitHub] kafka pull request: KIP-28: First patch

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

Jenkins build is back to normal : Kafka-trunk #642

See

[jira] [Commented] (KAFKA-2434) remove roundrobin identical topic constraint in consumer coordinator (old API)

[ https://issues.apache.org/jira/browse/KAFKA-2434?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14908997#comment-14908997 ] Jun Rao commented on KAFKA-2434: [~andy_k], thanks for the patch. It seems the algorithm i

[jira] [Commented] (KAFKA-2581) Run all existing ducktape tests with SSL-enabled clients and brokers

[ https://issues.apache.org/jira/browse/KAFKA-2581?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14909033#comment-14909033 ] Ewen Cheslack-Postava commented on KAFKA-2581: -- Excellent, that's much better

[jira] [Commented] (KAFKA-2374) Implement Copycat log/file connector

[ https://issues.apache.org/jira/browse/KAFKA-2374?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14909045#comment-14909045 ] Ewen Cheslack-Postava commented on KAFKA-2374: -- Absolutely. And it makes me e

[jira] [Resolved] (KAFKA-2374) Implement Copycat log/file connector

[ https://issues.apache.org/jira/browse/KAFKA-2374?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava resolved KAFKA-2374. -- Resolution: Fixed Resolved via earlier commits & the FileStreamSource and FileSt

[jira] [Commented] (KAFKA-2448) BrokerChangeListener missed broker id path ephemeral node deletion event.

[ https://issues.apache.org/jira/browse/KAFKA-2448?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14909062#comment-14909062 ] Jiangjie Qin commented on KAFKA-2448: - [~junrao], thanks for the comment. Yes, that is

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

[ https://issues.apache.org/jira/browse/KAFKA-2480?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin updated KAFKA-2480: Assignee: Liquan Pei (was: Ewen Cheslack-Postava) > Handle non-CopycatExceptions from SinkTasks > -

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

[ https://issues.apache.org/jira/browse/KAFKA-2480?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14909064#comment-14909064 ] Jiangjie Qin commented on KAFKA-2480: - [~ishiihara], you might want to ask one of the

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

The basic functionality is definitely useful here. I'm generally in favor of exposing some info about broker versions to clients. I'd prefer to keep the key/values explicit. Making them extensible string/string pairs is good for avoiding unnecessary version changes in the protocol, but I think we