[jira] [Commented] (KAFKA-1595) Remove deprecated and slower scala JSON parser from kafka.consumer.TopicCount

[ https://issues.apache.org/jira/browse/KAFKA-1595?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14512901#comment-14512901 ] Ismael Juma commented on KAFKA-1595: Hi Gwen, thanks for the useful feedback. Regardin

Re: [VOTE] KIP-11- Authorization design for kafka security

Thanks for clarifying, Parth. I think you are taking the right approach here. On Fri, Apr 24, 2015 at 11:46 AM, Parth Brahmbhatt wrote: > Sorry Gwen, completely misunderstood the question :-). > > * Does everyone have the privilege to create a new Group and use it to > consume from Topics he's al

[jira] [Updated] (KAFKA-1595) Remove deprecated and slower scala JSON parser from kafka.consumer.TopicCount

[ https://issues.apache.org/jira/browse/KAFKA-1595?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira updated KAFKA-1595: Status: In Progress (was: Patch Available) > Remove deprecated and slower scala JSON parser from ka

[jira] [Commented] (KAFKA-1595) Remove deprecated and slower scala JSON parser from kafka.consumer.TopicCount

[ https://issues.apache.org/jira/browse/KAFKA-1595?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14512881#comment-14512881 ] Gwen Shapira commented on KAFKA-1595: - 1. I believe the wide agreement was to use Fast

[jira] [Updated] (KAFKA-1334) Add failure detection capability to the coordinator / consumer

[ https://issues.apache.org/jira/browse/KAFKA-1334?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Onur Karaman updated KAFKA-1334: Attachment: KAFKA-1334_2015-04-25_17:57:37.patch > Add failure detection capability to the coordinat

[jira] [Commented] (KAFKA-1334) Add failure detection capability to the coordinator / consumer

[ https://issues.apache.org/jira/browse/KAFKA-1334?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14512810#comment-14512810 ] Onur Karaman commented on KAFKA-1334: - Updated reviewboard https://reviews.apache.org/

Re: Review Request 33088: add heartbeat to coordinator

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/33088/ --- (Updated April 26, 2015, 12:57 a.m.) Review request for kafka. Bugs: KAFKA-13

[jira] [Commented] (KAFKA-1936) Track offset commit requests separately from produce requests

[ https://issues.apache.org/jira/browse/KAFKA-1936?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14512768#comment-14512768 ] Dong Lin commented on KAFKA-1936: - Created reviewboard https://reviews.apache.org/r/33557/

[jira] [Updated] (KAFKA-1936) Track offset commit requests separately from produce requests

[ https://issues.apache.org/jira/browse/KAFKA-1936?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-1936: Status: Patch Available (was: Open) > Track offset commit requests separately from produce requests > -

[jira] [Updated] (KAFKA-1936) Track offset commit requests separately from produce requests

[ https://issues.apache.org/jira/browse/KAFKA-1936?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-1936: Attachment: KAFKA-1936.patch > Track offset commit requests separately from produce requests > -

Review Request 33557: Patch for KAFKA-1936

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/33557/ --- Review request for kafka. Bugs: KAFKA-1936 https://issues.apache.org/jira/b

[jira] [Commented] (KAFKA-1334) Add failure detection capability to the coordinator / consumer

[ https://issues.apache.org/jira/browse/KAFKA-1334?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14512752#comment-14512752 ] Onur Karaman commented on KAFKA-1334: - Updated reviewboard https://reviews.apache.org/

Re: Review Request 33088: add heartbeat to coordinator

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/33088/ --- (Updated April 25, 2015, 10:21 p.m.) Review request for kafka. Bugs: KAFKA-13

[jira] [Updated] (KAFKA-1334) Add failure detection capability to the coordinator / consumer

[ https://issues.apache.org/jira/browse/KAFKA-1334?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Onur Karaman updated KAFKA-1334: Attachment: KAFKA-1334_2015-04-25_15:21:25.patch > Add failure detection capability to the coordinat

[jira] [Updated] (KAFKA-1595) Remove deprecated and slower scala JSON parser from kafka.consumer.TopicCount

[ https://issues.apache.org/jira/browse/KAFKA-1595?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-1595: - Reviewer: Jun Rao (was: Jun Li) > Remove deprecated and slower scala JSON parser from kafka.consu

[jira] [Updated] (KAFKA-1595) Remove deprecated and slower scala JSON parser from kafka.consumer.TopicCount

[ https://issues.apache.org/jira/browse/KAFKA-1595?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-1595: - Reviewer: Jun Li > Remove deprecated and slower scala JSON parser from kafka.consumer.TopicCount >

Re: Review Request 33410: Patch for KAFKA-2034

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/33410/#review81600 --- Ship it! Ship It! - Neha Narkhede On April 21, 2015, 9 p.m., Ism

[jira] [Updated] (KAFKA-2150) FetcherThread backoff need to grab lock before wait on condition.

[ https://issues.apache.org/jira/browse/KAFKA-2150?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sriharsha Chintalapani updated KAFKA-2150: -- Attachment: KAFKA-2150_2015-04-25_13:35:36.patch > FetcherThread backoff need to

[jira] [Commented] (KAFKA-2150) FetcherThread backoff need to grab lock before wait on condition.

[ https://issues.apache.org/jira/browse/KAFKA-2150?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14512701#comment-14512701 ] Sriharsha Chintalapani commented on KAFKA-2150: --- Updated reviewboard https:/

Re: Review Request 33551: Patch for KAFKA-2150

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/33551/ --- (Updated April 25, 2015, 8:35 p.m.) Review request for kafka. Bugs: KAFKA-215

Re: Review Request 33551: Patch for KAFKA-2150

> On April 25, 2015, 7:20 p.m., Aditya Auradkar wrote: > > core/src/main/scala/kafka/server/AbstractFetcherThread.scala, line 95 > > > > > > I was thinking that you could still process the fetchRequest outside > > the

[jira] [Updated] (KAFKA-2150) FetcherThread backoff need to grab lock before wait on condition.

[ https://issues.apache.org/jira/browse/KAFKA-2150?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sriharsha Chintalapani updated KAFKA-2150: -- Attachment: KAFKA-2150_2015-04-25_13:18:35.patch > FetcherThread backoff need to

[jira] [Commented] (KAFKA-2150) FetcherThread backoff need to grab lock before wait on condition.

[ https://issues.apache.org/jira/browse/KAFKA-2150?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14512688#comment-14512688 ] Sriharsha Chintalapani commented on KAFKA-2150: --- Updated reviewboard https:/

Re: Review Request 33551: Patch for KAFKA-2150

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/33551/ --- (Updated April 25, 2015, 8:18 p.m.) Review request for kafka. Bugs: KAFKA-215

Re: Review Request 33551: Patch for KAFKA-2150

> On April 25, 2015, 7:20 p.m., Aditya Auradkar wrote: > > core/src/main/scala/kafka/server/AbstractFetcherThread.scala, line 95 > > > > > > I was thinking that you could still process the fetchRequest outside > > the

[jira] [Updated] (KAFKA-2150) FetcherThread backoff need to grab lock before wait on condition.

[ https://issues.apache.org/jira/browse/KAFKA-2150?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sriharsha Chintalapani updated KAFKA-2150: -- Attachment: KAFKA-2150_2015-04-25_13:14:05.patch > FetcherThread backoff need to

[jira] [Commented] (KAFKA-2150) FetcherThread backoff need to grab lock before wait on condition.

[ https://issues.apache.org/jira/browse/KAFKA-2150?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14512686#comment-14512686 ] Sriharsha Chintalapani commented on KAFKA-2150: --- Updated reviewboard https:/

Re: Review Request 33551: Patch for KAFKA-2150

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/33551/ --- (Updated April 25, 2015, 8:14 p.m.) Review request for kafka. Bugs: KAFKA-215

Re: Review Request 33551: Patch for KAFKA-2150

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/33551/#review81596 --- core/src/main/scala/kafka/server/AbstractFetcherThread.scala

Re: Review Request 33552: Patch for KAFKA-2142

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/33552/ --- (Updated April 25, 2015, 6:49 p.m.) Review request for kafka. Bugs: KAFKA-214

[jira] [Updated] (KAFKA-2142) Follow-up patch for KAFKA-2138 Refactor the drain message logic in new producer

[ https://issues.apache.org/jira/browse/KAFKA-2142?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin updated KAFKA-2142: Attachment: KAFKA-2142_2015-04-25_11:48:09.patch > Follow-up patch for KAFKA-2138 Refactor the drain

[jira] [Commented] (KAFKA-2142) Follow-up patch for KAFKA-2138 Refactor the drain message logic in new producer

[ https://issues.apache.org/jira/browse/KAFKA-2142?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14512654#comment-14512654 ] Jiangjie Qin commented on KAFKA-2142: - Updated reviewboard https://reviews.apache.org/

Re: Review Request 33552: Patch for KAFKA-2142

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/33552/ --- (Updated April 25, 2015, 6:48 p.m.) Review request for kafka. Bugs: KAFKA-214

Re: Review Request 33552: Patch for KAFKA-2142

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/33552/ --- (Updated April 25, 2015, 6:25 p.m.) Review request for kafka. Bugs: KAFKA-214

Re: Review Request 33552: Patch for KAFKA-2142

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/33552/ --- (Updated April 25, 2015, 6:22 p.m.) Review request for kafka. Bugs: KAFKA-214

[jira] [Commented] (KAFKA-2142) Follow-up patch for KAFKA-2138 Refactor the drain message logic in new producer

[ https://issues.apache.org/jira/browse/KAFKA-2142?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14512637#comment-14512637 ] Jiangjie Qin commented on KAFKA-2142: - Created reviewboard https://reviews.apache.org/

[jira] [Updated] (KAFKA-2142) Follow-up patch for KAFKA-2138 Refactor the drain message logic in new producer

[ https://issues.apache.org/jira/browse/KAFKA-2142?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin updated KAFKA-2142: Attachment: KAFKA-2142.patch > Follow-up patch for KAFKA-2138 Refactor the drain message logic in ne

[jira] [Updated] (KAFKA-2142) Follow-up patch for KAFKA-2138 Refactor the drain message logic in new producer

[ https://issues.apache.org/jira/browse/KAFKA-2142?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin updated KAFKA-2142: Status: Patch Available (was: Open) > Follow-up patch for KAFKA-2138 Refactor the drain message log

Review Request 33552: Patch for KAFKA-2142

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/33552/ --- Review request for kafka. Bugs: KAFKA-2142 https://issues.apache.org/jira/b

Re: Review Request 33551: Patch for KAFKA-2150

> On April 25, 2015, 4:18 p.m., Aditya Auradkar wrote: > > core/src/main/scala/kafka/server/AbstractFetcherThread.scala, line 95 > > > > > > The way this function is implemented, it potentially acquires the same > > lo

Re: Review Request 33551: Patch for KAFKA-2150

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/33551/#review81593 --- Minor comment. core/src/main/scala/kafka/server/AbstractFetcherThr

[jira] [Updated] (KAFKA-2150) FetcherThread backoff need to grab lock before wait on condition.

[ https://issues.apache.org/jira/browse/KAFKA-2150?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sriharsha Chintalapani updated KAFKA-2150: -- Assignee: Sriharsha Chintalapani Status: Patch Available (was: Open) > Fe

Review Request 33551: Patch for KAFKA-2150

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/33551/ --- Review request for kafka. Bugs: KAFKA-2150 https://issues.apache.org/jira/b

[jira] [Updated] (KAFKA-2150) FetcherThread backoff need to grab lock before wait on condition.

[ https://issues.apache.org/jira/browse/KAFKA-2150?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sriharsha Chintalapani updated KAFKA-2150: -- Attachment: KAFKA-2150.patch > FetcherThread backoff need to grab lock before wa

[jira] [Commented] (KAFKA-2150) FetcherThread backoff need to grab lock before wait on condition.

[ https://issues.apache.org/jira/browse/KAFKA-2150?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14512519#comment-14512519 ] Sriharsha Chintalapani commented on KAFKA-2150: --- Created reviewboard https:/

Re: [DISCUSS] KIP-4 - Command line and centralized administrative operations (Thread 2)

Guys, Can we come to some agreement in terms of the second item from the email above? This blocks me from updating and uploading the patch. Also the new schedule for the weekly calls doesn't work very well for me - it's 1 am in my timezone :) - so I'd rather we confirm everything that is possible

[jira] [Commented] (KAFKA-2034) sourceCompatibility not set in Kafka build.gradle

[ https://issues.apache.org/jira/browse/KAFKA-2034?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14512468#comment-14512468 ] Ismael Juma commented on KAFKA-2034: Unassigning myself as a committer needs to merge

[jira] [Updated] (KAFKA-2034) sourceCompatibility not set in Kafka build.gradle

[ https://issues.apache.org/jira/browse/KAFKA-2034?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-2034: --- Assignee: (was: Ismael Juma) > sourceCompatibility not set in Kafka build.gradle > ---

[GitHub] kafka pull request: Merge pull request #1 from apache/trunk

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

[GitHub] kafka pull request: Merge pull request #1 from apache/trunk

GitHub user mastersingh24 opened a pull request: https://github.com/apache/kafka/pull/56 Merge pull request #1 from apache/trunk Trunk You can merge this pull request into a Git repository by running: $ git pull https://github.com/mastersingh24/kafka trunk Alternatively you ca

[jira] [Commented] (KAFKA-2068) Replace OffsetCommit Request/Response with org.apache.kafka.common.requests equivalent

[ https://issues.apache.org/jira/browse/KAFKA-2068?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14512330#comment-14512330 ] Guozhang Wang commented on KAFKA-2068: -- First step is to merge in KAFKA-1841, will wa

[jira] [Updated] (KAFKA-2068) Replace OffsetCommit Request/Response with org.apache.kafka.common.requests equivalent

[ https://issues.apache.org/jira/browse/KAFKA-2068?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-2068: - Reviewer: Jun Rao > Replace OffsetCommit Request/Response with org.apache.kafka.common.requests

Re: Review Request 33548: KAFKA-2068 Step I: merge in KAFKA-1841

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/33548/ --- (Updated April 25, 2015, 7:59 a.m.) Review request for kafka. Bugs: KAFKA-206

[jira] [Commented] (KAFKA-2068) Replace OffsetCommit Request/Response with org.apache.kafka.common.requests equivalent

[ https://issues.apache.org/jira/browse/KAFKA-2068?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14512328#comment-14512328 ] Guozhang Wang commented on KAFKA-2068: -- Created reviewboard https://reviews.apache.or

[jira] [Updated] (KAFKA-2068) Replace OffsetCommit Request/Response with org.apache.kafka.common.requests equivalent

[ https://issues.apache.org/jira/browse/KAFKA-2068?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-2068: - Attachment: KAFKA-2068.patch > Replace OffsetCommit Request/Response with org.apache.kafka.common

[jira] [Updated] (KAFKA-2068) Replace OffsetCommit Request/Response with org.apache.kafka.common.requests equivalent

[ https://issues.apache.org/jira/browse/KAFKA-2068?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-2068: - Status: Patch Available (was: Open) > Replace OffsetCommit Request/Response with org.apache.kafk

Review Request 33548: KAFKA-2068 Step I: merge in KAFKA-1841

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/33548/ --- Review request for kafka. Bugs: KAFKA-2068 https://issues.apache.org/jira/b

[jira] [Commented] (KAFKA-2150) FetcherThread backoff need to grab lock before wait on condition.

[ https://issues.apache.org/jira/browse/KAFKA-2150?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14512326#comment-14512326 ] Jiangjie Qin commented on KAFKA-2150: - This is introduced in KAFKA-1461. Fix should be

[jira] [Created] (KAFKA-2150) FetcherThread backoff need to grab lock before wait on condition.

Jiangjie Qin created KAFKA-2150: --- Summary: FetcherThread backoff need to grab lock before wait on condition. Key: KAFKA-2150 URL: https://issues.apache.org/jira/browse/KAFKA-2150 Project: Kafka