[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=15884519#comment-15884519 ] songxin edited comment on KAFKA-3900 at 2/26/17 4:12 AM: - I meet the same problem

[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=15884519#comment-15884519 ] songxin edited comment on KAFKA-3900 at 2/26/17 4:11 AM: - I meet the same problem

[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=15884519#comment-15884519 ] songxin edited comment on KAFKA-3900 at 2/26/17 4:09 AM: - I meet the same issue

[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=15884519#comment-15884519 ] songxin commented on KAFKA-3900: I meet the same issue two。After this happen,there will be a punch of

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

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

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

[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

[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=15884419#comment-15884419 ] Jiangjie Qin commented on KAFKA-3436: - Sorry you are right. I was under the impression that patch was

[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=15884414#comment-15884414 ] James Cheng commented on KAFKA-3436: I haven't had a chance to try trunk. Is it on trunk but not in

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

[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

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

[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=15884411#comment-15884411 ] ASF GitHub Bot commented on KAFKA-4784: --- Github user ewencp closed the pull request at:

[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

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

[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

[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

[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

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

[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=15884390#comment-15884390 ] Jiangjie Qin commented on KAFKA-3436: - [~onurkaraman] is currently working on rewrite controller. The

[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

[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

[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

[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=15884381#comment-15884381 ] Ewen Cheslack-Postava commented on KAFKA-4798: -- [~wushujames] Just pushed an unrelated update

[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=15884378#comment-15884378 ] Ewen Cheslack-Postava commented on KAFKA-4798: -- [~wushujames] Seems like something's up with

[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=15884375#comment-15884375 ] Ewen Cheslack-Postava commented on KAFKA-4793: -- To clarify for anyone that happens upon this,

[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=15884373#comment-15884373 ] James Cheng commented on KAFKA-4798: [~ewencp], it's been 20-ish hours, and the pages still say

[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=15884360#comment-15884360 ] Ewen Cheslack-Postava commented on KAFKA-4798: -- [~guozhang] The fonts/`resources` stuff is

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

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

[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=15884183#comment-15884183 ] ASF GitHub Bot commented on KAFKA-4196: --- Github user original-brownbear closed the pull request at:

[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