[jira] [Comment Edited] (KAFKA-3900) High CPU util on broker

[ https://issues.apache.org/jira/browse/KAFKA-3900?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15884519#comment-15884519 ] songxin edited comment on KAFKA-3900 at 2/26/17 4:12 AM: - I meet t

[jira] [Comment Edited] (KAFKA-3900) High CPU util on broker

[ https://issues.apache.org/jira/browse/KAFKA-3900?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15884519#comment-15884519 ] songxin edited comment on KAFKA-3900 at 2/26/17 4:11 AM: - I meet t

[jira] [Comment Edited] (KAFKA-3900) High CPU util on broker

[ https://issues.apache.org/jira/browse/KAFKA-3900?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15884519#comment-15884519 ] songxin edited comment on KAFKA-3900 at 2/26/17 4:09 AM: - I meet t

[jira] [Commented] (KAFKA-3900) High CPU util on broker

[ https://issues.apache.org/jira/browse/KAFKA-3900?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15884519#comment-15884519 ] songxin commented on KAFKA-3900: I meet the same issue two。After this happen,there will be

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

See Changes: [me] MINOR: Use API hyperlinks in 'Kafka Protocol Guide' to facilitate -- [...truncated 159.32 KB...] kafka.utils.timer.TimerTest > testTaskExpiration STARTE

Re: [DISCUSS] KIP-112: Handle disk failure for JBOD

Hey Jun, Thanks for the suggestion. I think it is a good idea to know put created flag in ZK and simply specify isNewReplica=true in LeaderAndIsrRequest if repilcas was in NewReplica state. It will only fail the replica creation in the scenario that the controller fails after topic-creation/partit

Re: [DISCUSS] KIP-128: Add ByteArrayConverter for Kafka Connect

I'm wondering why we can't just use ByteArarySerde in o.a.k.common? Guozhang On Sat, Feb 25, 2017 at 2:25 PM, Ewen Cheslack-Postava wrote: > Hi all, > > I've added a pretty trivial KIP for adding a pass-through Converter for > Kafka Connect, similar to ByteArraySerializer/Deserializer. > > http

[GitHub] kafka pull request #2467: MINOR: Use API hyperlinks in 'Kafka Protocol Guide...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/2467 --- 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-3436) Speed up controlled shutdown.

[ https://issues.apache.org/jira/browse/KAFKA-3436?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15884419#comment-15884419 ] Jiangjie Qin commented on KAFKA-3436: - Sorry you are right. I was under the impression

[jira] [Commented] (KAFKA-3436) Speed up controlled shutdown.

[ https://issues.apache.org/jira/browse/KAFKA-3436?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15884414#comment-15884414 ] James Cheng commented on KAFKA-3436: I haven't had a chance to try trunk. Is it on tru

Re: [DISCUSS] KIP-82 - Add Record Headers

Hey Michael, Thanks for the KIP. It looks good overall and it looks we only have few things to agree on. 1. Regarding the mutability. I think it would be a big convenience to have headers mutable during certain stage in the message life cycle for the use cases you mentioned. I agree there is a m

[DISCUSS] KIP-128: Add ByteArrayConverter for Kafka Connect

Hi all, I've added a pretty trivial KIP for adding a pass-through Converter for Kafka Connect, similar to ByteArraySerializer/Deserializer. https://cwiki.apache.org/confluence/display/KAFKA/KIP-128%3A+Add+ByteArrayConverter+for+Kafka+Connect This wasn't added with the framework originally becaus

[jira] [Updated] (KAFKA-4783) Blackbox or pass through converter or ByteArrayConverter for connect

[ https://issues.apache.org/jira/browse/KAFKA-4783?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-4783: - Fix Version/s: 0.10.3.0 Status: Patch Available (was: In Progress) > B

[jira] [Commented] (KAFKA-4784) Pluggable JAAS LoginModule configuration for SSL (KIP-127)

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

[GitHub] kafka pull request #2599: KAFKA-4783: Add ByteArrayConverter (KIP-128)

GitHub user ewencp opened a pull request: https://github.com/apache/kafka/pull/2599 KAFKA-4783: Add ByteArrayConverter (KIP-128) You can merge this pull request into a Git repository by running: $ git pull https://github.com/ewencp/kafka kafka-4783-byte-array-converter Altern

[jira] [Commented] (KAFKA-4783) Blackbox or pass through converter or ByteArrayConverter for connect

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

[jira] [Work started] (KAFKA-4783) Blackbox or pass through converter or ByteArrayConverter for connect

[ https://issues.apache.org/jira/browse/KAFKA-4783?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on KAFKA-4783 started by Ewen Cheslack-Postava. > Blackbox or pass through converter or ByteArrayConverter for co

[jira] [Work stopped] (KAFKA-4783) Blackbox or pass through converter or ByteArrayConverter for connect

[ https://issues.apache.org/jira/browse/KAFKA-4783?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on KAFKA-4783 stopped by Ewen Cheslack-Postava. > Blackbox or pass through converter or ByteArrayConverter for co

[jira] [Work started] (KAFKA-4783) Blackbox or pass through converter or ByteArrayConverter for connect

[ https://issues.apache.org/jira/browse/KAFKA-4783?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on KAFKA-4783 started by Ewen Cheslack-Postava. > Blackbox or pass through converter or ByteArrayConverter for co

[GitHub] kafka pull request #2598: KAFKA-4784: Add ByteArrayConverter (KIP-128)

Github user ewencp closed the pull request at: https://github.com/apache/kafka/pull/2598 --- 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-4784) Pluggable JAAS LoginModule configuration for SSL (KIP-127)

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

[GitHub] kafka pull request #2598: KAFKA-4784: Add ByteArrayConverter (KIP-128)

GitHub user ewencp opened a pull request: https://github.com/apache/kafka/pull/2598 KAFKA-4784: Add ByteArrayConverter (KIP-128) You can merge this pull request into a Git repository by running: $ git pull https://github.com/ewencp/kafka kafka-4784-byte-array-converter Altern

[jira] [Commented] (KAFKA-3436) Speed up controlled shutdown.

[ https://issues.apache.org/jira/browse/KAFKA-3436?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15884390#comment-15884390 ] Jiangjie Qin commented on KAFKA-3436: - [~onurkaraman] is currently working on rewrite

[jira] [Updated] (KAFKA-4783) Blackbox or pass through converter or ByteArrayConverter for connect

[ https://issues.apache.org/jira/browse/KAFKA-4783?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-4783: - Labels: needs-kip (was: ) > Blackbox or pass through converter or ByteArrayConver

[jira] [Assigned] (KAFKA-4783) Blackbox or pass through converter or ByteArrayConverter for connect

[ https://issues.apache.org/jira/browse/KAFKA-4783?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava reassigned KAFKA-4783: Assignee: Ewen Cheslack-Postava > Blackbox or pass through converter or Byt

[jira] [Resolved] (KAFKA-4798) Javadocs for 0.10.2 are missing from kafka.apache.org

[ https://issues.apache.org/jira/browse/KAFKA-4798?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava resolved KAFKA-4798. -- Assignee: Ewen Cheslack-Postava > Javadocs for 0.10.2 are missing from kafka.apa

[jira] [Commented] (KAFKA-4798) Javadocs for 0.10.2 are missing from kafka.apache.org

[ https://issues.apache.org/jira/browse/KAFKA-4798?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15884381#comment-15884381 ] Ewen Cheslack-Postava commented on KAFKA-4798: -- [~wushujames] Just pushed an

[jira] [Commented] (KAFKA-4798) Javadocs for 0.10.2 are missing from kafka.apache.org

[ https://issues.apache.org/jira/browse/KAFKA-4798?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15884378#comment-15884378 ] Ewen Cheslack-Postava commented on KAFKA-4798: -- [~wushujames] Seems like some

[jira] [Commented] (KAFKA-4793) Kafka Connect: POST /connectors/(string: name)/restart doesn't start failed tasks

[ https://issues.apache.org/jira/browse/KAFKA-4793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15884375#comment-15884375 ] Ewen Cheslack-Postava commented on KAFKA-4793: -- To clarify for anyone that ha

[jira] [Commented] (KAFKA-4798) Javadocs for 0.10.2 are missing from kafka.apache.org

[ https://issues.apache.org/jira/browse/KAFKA-4798?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15884373#comment-15884373 ] James Cheng commented on KAFKA-4798: [~ewencp], it's been 20-ish hours, and the pages

[jira] [Commented] (KAFKA-4798) Javadocs for 0.10.2 are missing from kafka.apache.org

[ https://issues.apache.org/jira/browse/KAFKA-4798?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15884360#comment-15884360 ] Ewen Cheslack-Postava commented on KAFKA-4798: -- [~guozhang] The fonts/`resour

Re: New subscriber

Hello Huimin, This is a self-service mailing list, see https://kafka.apache.org/contact On Fri, Feb 24, 2017 at 4:39 PM, Huimin He wrote: > My name is Huimin He. I want to subscribe to the mail list. > > Thanks, > Huimin He > -- -- Guozhang

[GitHub] kafka pull request #2597: KAFKA-4652: Added tests for KStreamBuilder

GitHub user bbejeck opened a pull request: https://github.com/apache/kafka/pull/2597 KAFKA-4652: Added tests for KStreamBuilder You can merge this pull request into a Git repository by running: $ git pull https://github.com/bbejeck/kafka KAFKA-4652_improve_kstream_builder_tes

[jira] [Commented] (KAFKA-4652) Improve test coverage KStreamBuilder

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

Re: [DISCUSS] KIP-112: Handle disk failure for JBOD

Hi, Dong, Thanks for the reply. Personally, I'd prefer not to write the created flag per replica in ZK. Your suggestion of disabling replica creation if there is a bad log directory on the broker could work. The only thing is that it may delay the creation of new replicas. I was thinking that an

[GitHub] kafka pull request #2570: KAFKA-4196: Improved Test Stability

Github user original-brownbear closed the pull request at: https://github.com/apache/kafka/pull/2570 --- 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 fea

[jira] [Commented] (KAFKA-4196) Transient test failure: DeleteConsumerGroupTest.testConsumptionOnRecreatedTopicAfterTopicWideDeleteInZK

[ https://issues.apache.org/jira/browse/KAFKA-4196?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15884183#comment-15884183 ] ASF GitHub Bot commented on KAFKA-4196: --- Github user original-brownbear closed the p