[jira] [Commented] (KAFKA-1982) change kafka.examples.Producer to use the new java producer

[ https://issues.apache.org/jira/browse/KAFKA-1982?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14335999#comment-14335999 ] Ashish K Singh commented on KAFKA-1982: --- Updated reviewboard https://reviews.apache.

[jira] [Updated] (KAFKA-1982) change kafka.examples.Producer to use the new java producer

[ https://issues.apache.org/jira/browse/KAFKA-1982?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ashish K Singh updated KAFKA-1982: -- Attachment: KAFKA-1982_2015-02-24_20:48:12.patch > change kafka.examples.Producer to use the new

Re: Review Request 31369: Patch for KAFKA-1982

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/31369/ --- (Updated Feb. 25, 2015, 4:48 a.m.) Review request for kafka. Bugs: KAFKA-1982

[jira] [Updated] (KAFKA-1982) change kafka.examples.Producer to use the new java producer

[ https://issues.apache.org/jira/browse/KAFKA-1982?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ashish K Singh updated KAFKA-1982: -- Attachment: KAFKA-1982_2015-02-24_20:45:48.patch > change kafka.examples.Producer to use the new

[jira] [Commented] (KAFKA-1982) change kafka.examples.Producer to use the new java producer

[ https://issues.apache.org/jira/browse/KAFKA-1982?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14335994#comment-14335994 ] Ashish K Singh commented on KAFKA-1982: --- Updated reviewboard https://reviews.apache.

Re: Review Request 31369: Patch for KAFKA-1982

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/31369/ --- (Updated Feb. 25, 2015, 4:45 a.m.) Review request for kafka. Bugs: KAFKA-1982

[jira] [Commented] (KAFKA-1864) Revisit defaults for the internal offsets topic

[ https://issues.apache.org/jira/browse/KAFKA-1864?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14335978#comment-14335978 ] Gwen Shapira commented on KAFKA-1864: - Probably not the right place for this discussio

Re: [VOTE] KIP-8: Add a flush() method to the new producer

KIP-8 is adopted with 6 +1 and no dissenting votes. On Thu, Feb 19, 2015 at 12:14 PM, Sriram Subramanian < srsubraman...@linkedin.com.invalid> wrote: > +1 > > On 2/19/15 12:08 PM, "Neha Narkhede" wrote: > > >+1 (binding) > > > >On Thu, Feb 19, 2015 at 6:29 AM, Joel Koshy wrote: > > > >> +1 (bin

Re: [VOTE] KIP-3 Mirror Maker Enhancement

+1 binding On Tue, Feb 24, 2015 at 5:24 PM, Gwen Shapira wrote: > +1 (non-binding) > > On Tue, Feb 24, 2015 at 5:14 PM, Jiangjie Qin > wrote: > > > > > > https://cwiki.apache.org/confluence/display/KAFKA/KIP-3+-+Mirror+Maker+Enhancement > > > > +1 > > > -- -- Guozhang

Re: Review Request 31385: Patch for KAFKA-1978

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/31385/#review73963 --- >From the diff file itself it's a bit hard to understand the issue a

Re: [KIP-DISCUSSION] Mirror Maker Enhancement

Sure! Just created the voting thread :) On 2/24/15, 4:44 PM, "Jay Kreps" wrote: >Hey Jiangjie, > >Let's do an official vote so that we know what we are voting on and we are >crisp on what the outcome was. This thread is very long :- > >-Jay > >On Tue, Feb 24, 2015 at 2:53 PM, Jiangjie Qin >wrot

Re: [VOTE] KIP-3 Mirror Maker Enhancement

+1 (non-binding) On Tue, Feb 24, 2015 at 5:14 PM, Jiangjie Qin wrote: > > https://cwiki.apache.org/confluence/display/KAFKA/KIP-3+-+Mirror+Maker+Enhancement > > +1 >

[VOTE] KIP-3 Mirror Maker Enhancement

https://cwiki.apache.org/confluence/display/KAFKA/KIP-3+-+Mirror+Maker+Enhancement +1

Re: [KIP-DISCUSSION] Mirror Maker Enhancement

Hey Jiangjie, Let's do an official vote so that we know what we are voting on and we are crisp on what the outcome was. This thread is very long :-) -Jay On Tue, Feb 24, 2015 at 2:53 PM, Jiangjie Qin wrote: > I updated the KIP page based on the discussion we had. > > Should I launch another vo

[jira] [Commented] (KAFKA-1978) Replication test_0131 system test has been failing.

[ https://issues.apache.org/jira/browse/KAFKA-1978?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14335663#comment-14335663 ] Abhishek Nigam commented on KAFKA-1978: --- Created reviewboard https://reviews.apache.

[jira] [Updated] (KAFKA-1978) Replication test_0131 system test has been failing.

[ https://issues.apache.org/jira/browse/KAFKA-1978?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Abhishek Nigam updated KAFKA-1978: -- Attachment: KAFKA-1978.patch > Replication test_0131 system test has been failing. > ---

[jira] [Updated] (KAFKA-1978) Replication test_0131 system test has been failing.

[ https://issues.apache.org/jira/browse/KAFKA-1978?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Abhishek Nigam updated KAFKA-1978: -- Status: Patch Available (was: Open) > Replication test_0131 system test has been failing. > ---

Review Request 31385: Patch for KAFKA-1978

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

Re: [KIP-DISCUSSION] Mirror Maker Enhancement

I forgot to mention that we have tested the entire design in our test environment. The performance looks fine. Jiangjie (Becket) Qin On 2/24/15, 2:53 PM, "Jiangjie Qin" wrote: >I updated the KIP page based on the discussion we had. > >Should I launch another vote or we can think of this mail th

Re: [KIP-DISCUSSION] Mirror Maker Enhancement

I updated the KIP page based on the discussion we had. Should I launch another vote or we can think of this mail thread has already included a vote? Jiangjie (Becket) Qin On 2/11/15, 5:15 PM, "Neha Narkhede" wrote: >Thanks for the explanation, Joel! Would love to see the results of the >throug

Build failed in Jenkins: KafkaPreCommit #19

See Changes: [junrao] kafka-1984; java producer may miss an available partition; patched by Jun Rao; reviewed by Ewen Cheslack-Postava, Jay Kreps, and Guozhang Wang -- [...truncated 1858 lines...]

Re: [kafka-clients] Re: [VOTE] 0.8.2.1 Candidate 1

Joe, It turns out that KAFKA-1724 is already resolved in trunk through another jira. However, the change in that jira is big. Since KAFKA-1724 seems to only happen when there is ZK session timeout or the ZK service is not available, I don't think it's worth fixing the issue in 0.8.2. Thanks, Jun

[jira] [Updated] (KAFKA-1724) Errors after reboot in single node setup

[ https://issues.apache.org/jira/browse/KAFKA-1724?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-1724: --- Resolution: Fixed Status: Resolved (was: Patch Available) > Errors after reboot in single node setup

Build failed in Jenkins: Kafka-trunk #406

See Changes: [junrao] kafka-1984; java producer may miss an available partition; patched by Jun Rao; reviewed by Ewen Cheslack-Postava, Jay Kreps, and Guozhang Wang -- [...truncated 1681 lines...]

[jira] [Updated] (KAFKA-1984) java producer may miss an available partition

[ https://issues.apache.org/jira/browse/KAFKA-1984?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-1984: --- Resolution: Fixed Status: Resolved (was: Patch Available) Thanks for the reviews. Committed to 0.8.2

[jira] [Commented] (KAFKA-1660) Ability to call close() with a timeout on the Java Kafka Producer.

[ https://issues.apache.org/jira/browse/KAFKA-1660?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14335546#comment-14335546 ] Guozhang Wang commented on KAFKA-1660: -- Parth, I am wondering if this new API can be

[jira] [Commented] (KAFKA-1978) Replication test_0131 system test has been failing.

[ https://issues.apache.org/jira/browse/KAFKA-1978?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14335535#comment-14335535 ] Guozhang Wang commented on KAFKA-1978: -- Abhishek, do you already have a patch for thi

[jira] [Updated] (KAFKA-1984) java producer may miss an available partition

[ https://issues.apache.org/jira/browse/KAFKA-1984?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-1984: --- Priority: Blocker (was: Major) Fix Version/s: 0.8.2.1 Marking this a blocker for 0.8.2.1 since it af

Re: Review Request 31363: Patch for kafka-1984

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/31363/#review73918 --- Ship it! Ship It! - Guozhang Wang On Feb. 24, 2015, 5:43 p.m., J

Re: Review Request 31367: Patch for kafka-1984

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/31367/#review73910 --- Ship it! Ship It! - Jay Kreps On Feb. 24, 2015, 6:16 p.m., Jun R

[jira] [Commented] (KAFKA-1864) Revisit defaults for the internal offsets topic

[ https://issues.apache.org/jira/browse/KAFKA-1864?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14335345#comment-14335345 ] Guozhang Wang commented on KAFKA-1864: -- I did not realize the change of "Math.min(con

Re: [DISCUSS] KIP-4 - Command line and centralized administrative operations

Let's stay on Google hangouts that will also record and make the sessions available on youtube. -Jay On Tue, Feb 24, 2015 at 11:49 AM, Jeff Holoman wrote: > Jay / Joe > > We're happy to send out a Webex for this purpose. We could record the > sessions if there is interest and publish them out.

Re: [DISCUSS] KIP-4 - Command line and centralized administrative operations

Jay / Joe We're happy to send out a Webex for this purpose. We could record the sessions if there is interest and publish them out. Thanks Jeff On Tue, Feb 24, 2015 at 11:28 AM, Jay Kreps wrote: > Let's try to get the technical hang-ups sorted out, though. I really think > there is some benef

[jira] [Commented] (KAFKA-1476) Get a list of consumer groups

[ https://issues.apache.org/jira/browse/KAFKA-1476?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14335283#comment-14335283 ] Neha Narkhede commented on KAFKA-1476: -- Good catch, [~ashishujjain]. Fixed it. > Get

[jira] [Commented] (KAFKA-1664) Kafka does not properly parse multiple ZK nodes with non-root chroot

[ https://issues.apache.org/jira/browse/KAFKA-1664?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14335255#comment-14335255 ] Ashish Singh commented on KAFKA-1664: - [~nehanarkhede] addressed the warnings issue. T

Re: Review Request 28108: Patch for KAFKA-1664

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/28108/ --- (Updated Feb. 24, 2015, 7:02 p.m.) Review request for kafka. Bugs: KAFKA-1664

[jira] [Commented] (KAFKA-1664) Kafka does not properly parse multiple ZK nodes with non-root chroot

[ https://issues.apache.org/jira/browse/KAFKA-1664?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14335248#comment-14335248 ] Ashish Singh commented on KAFKA-1664: - Updated reviewboard https://reviews.apache.org/

[jira] [Updated] (KAFKA-1664) Kafka does not properly parse multiple ZK nodes with non-root chroot

[ https://issues.apache.org/jira/browse/KAFKA-1664?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ashish Singh updated KAFKA-1664: Attachment: KAFKA-1664_2015-02-24_11:02:23.patch > Kafka does not properly parse multiple ZK nodes w

Build failed in Jenkins: Kafka-trunk #405

See Changes: [neha.narkhede] Added script for bin/kafka-consumer-groups.sh that was mistakenly dropped from the original patch for KAFKA-1476 -- Started by an SCM change Building remotely on ubuntu-5

[jira] [Commented] (KAFKA-1982) change kafka.examples.Producer to use the new java producer

[ https://issues.apache.org/jira/browse/KAFKA-1982?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14335203#comment-14335203 ] Ashish Singh commented on KAFKA-1982: - Updated reviewboard https://reviews.apache.org/

[jira] [Updated] (KAFKA-1982) change kafka.examples.Producer to use the new java producer

[ https://issues.apache.org/jira/browse/KAFKA-1982?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ashish Singh updated KAFKA-1982: Attachment: KAFKA-1982_2015-02-24_10:34:51.patch > change kafka.examples.Producer to use the new jav

Re: Review Request 31369: Patch for KAFKA-1982

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/31369/ --- (Updated Feb. 24, 2015, 6:35 p.m.) Review request for kafka. Bugs: KAFKA-1982

[jira] [Updated] (KAFKA-1982) change kafka.examples.Producer to use the new java producer

[ https://issues.apache.org/jira/browse/KAFKA-1982?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ashish Singh updated KAFKA-1982: Attachment: KAFKA-1982.patch > change kafka.examples.Producer to use the new java producer > ---

[jira] [Updated] (KAFKA-1982) change kafka.examples.Producer to use the new java producer

[ https://issues.apache.org/jira/browse/KAFKA-1982?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ashish Singh updated KAFKA-1982: Status: Patch Available (was: Open) > change kafka.examples.Producer to use the new java producer >

[jira] [Commented] (KAFKA-1982) change kafka.examples.Producer to use the new java producer

[ https://issues.apache.org/jira/browse/KAFKA-1982?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14335198#comment-14335198 ] Ashish Singh commented on KAFKA-1982: - Created reviewboard https://reviews.apache.org/

Review Request 31369: Patch for KAFKA-1982

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

[jira] [Commented] (KAFKA-1984) java producer may miss an available partition

[ https://issues.apache.org/jira/browse/KAFKA-1984?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14335183#comment-14335183 ] Jun Rao commented on KAFKA-1984: Created reviewboard https://reviews.apache.org/r/31367/di

Review Request 31367: Patch for kafka-1984

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

[jira] [Commented] (KAFKA-1984) java producer may miss an available partition

[ https://issues.apache.org/jira/browse/KAFKA-1984?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14335184#comment-14335184 ] Jun Rao commented on KAFKA-1984: Attaching a fix for 0.8.2 too. > java producer may miss

[jira] [Updated] (KAFKA-1984) java producer may miss an available partition

[ https://issues.apache.org/jira/browse/KAFKA-1984?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-1984: --- Attachment: kafka-1984.patch > java producer may miss an available partition > ---

Re: Review Request 31363: Patch for kafka-1984

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/31363/#review73840 --- Ship it! Minor nit, but LGTM. clients/src/test/java/org/apache/ka

[jira] [Commented] (KAFKA-1461) Replica fetcher thread does not implement any back-off behavior

[ https://issues.apache.org/jira/browse/KAFKA-1461?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14335166#comment-14335166 ] Sriharsha Chintalapani commented on KAFKA-1461: --- [~guozhang] thanks for the

[jira] [Updated] (KAFKA-1461) Replica fetcher thread does not implement any back-off behavior

[ https://issues.apache.org/jira/browse/KAFKA-1461?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sriharsha Chintalapani updated KAFKA-1461: -- Status: Patch Available (was: Open) > Replica fetcher thread does not implement

[jira] [Commented] (KAFKA-1461) Replica fetcher thread does not implement any back-off behavior

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

Review Request 31366: Patch for KAFKA-1461

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

[jira] [Updated] (KAFKA-1461) Replica fetcher thread does not implement any back-off behavior

[ https://issues.apache.org/jira/browse/KAFKA-1461?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sriharsha Chintalapani updated KAFKA-1461: -- Attachment: KAFKA-1461.patch > Replica fetcher thread does not implement any bac

[jira] [Commented] (KAFKA-1984) java producer may miss an available partition

[ https://issues.apache.org/jira/browse/KAFKA-1984?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14335141#comment-14335141 ] Jun Rao commented on KAFKA-1984: Created reviewboard https://reviews.apache.org/r/31363/di

[jira] [Updated] (KAFKA-1984) java producer may miss an available partition

[ https://issues.apache.org/jira/browse/KAFKA-1984?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-1984: --- Attachment: kafka-1984.patch > java producer may miss an available partition > ---

[jira] [Commented] (KAFKA-1984) java producer may miss an available partition

[ https://issues.apache.org/jira/browse/KAFKA-1984?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14335142#comment-14335142 ] Jun Rao commented on KAFKA-1984: There are actual two problems. 1. The way that we select

[jira] [Updated] (KAFKA-1984) java producer may miss an available partition

[ https://issues.apache.org/jira/browse/KAFKA-1984?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-1984: --- Status: Patch Available (was: Open) > java producer may miss an available partition > ---

Review Request 31363: Patch for kafka-1984

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

[jira] [Commented] (KAFKA-1980) Console consumer throws OutOfMemoryError with large max-messages

[ https://issues.apache.org/jira/browse/KAFKA-1980?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14335139#comment-14335139 ] Neha Narkhede commented on KAFKA-1980: -- Sorry, my bad. This was done by mistake as I

Build failed in Jenkins: KafkaPreCommit #18

See Changes: [neha.narkhede] Added script for bin/kafka-consumer-groups.sh that was mistakenly dropped from the original patch for KAFKA-1476 -- [...truncated 1629 lines...] kafka.admin.AdminTest >

Re: Review Request 30763: KAFKA-1865: Producer Flush: if at first your patch doesn't succeed, try, try, try again.

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/30763/#review73829 --- clients/src/main/java/org/apache/kafka/clients/producer/KafkaProduc

[jira] [Updated] (KAFKA-1596) Exception in KafkaScheduler while shutting down

[ https://issues.apache.org/jira/browse/KAFKA-1596?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sriharsha Chintalapani updated KAFKA-1596: -- Resolution: Duplicate Status: Resolved (was: Patch Available) This is i

[jira] [Commented] (KAFKA-1664) Kafka does not properly parse multiple ZK nodes with non-root chroot

[ https://issues.apache.org/jira/browse/KAFKA-1664?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14335053#comment-14335053 ] Neha Narkhede commented on KAFKA-1664: -- [~ashishujjain] Thanks for the reminder. The

Re: Review Request 28108: Patch for KAFKA-1664

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/28108/#review73825 --- Ship it! Ship It! - Neha Narkhede On Jan. 29, 2015, 6:26 p.m., A

[jira] [Updated] (KAFKA-1984) java producer may miss an available partition

[ https://issues.apache.org/jira/browse/KAFKA-1984?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-1984: - Component/s: producer > java producer may miss an available partition > -

Re: [DISCUSS] KIP-4 - Command line and centralized administrative operations

Let's try to get the technical hang-ups sorted out, though. I really think there is some benefit to live discussion vs writing. I am hopeful that if we post instructions and give ourselves a few attempts we can get it working. Tuesday at that time would work for me...any objections? -Jay On Tue,

Re: [DISCUSS] KIP-4 - Command line and centralized administrative operations

Weekly would be great maybe like every Tuesday ~ 1pm ET / 10am PT I don't mind google hangout but there is always some issue or whatever so we know the apache irc channel works. We can start there and see how it goes? We can pull transcripts too and associate to tickets if need be makes it he

Re: [DISCUSS] KIP-4 - Command line and centralized administrative operations

We'd talked about doing a Google Hangout to chat about this. What about generalizing that a little further...I actually think it would be good for everyone spending a reasonable chunk of their week on Kafka stuff to maybe sync up once a week. I think we could use time to talk through design stuff,

[jira] [Commented] (KAFKA-1980) Console consumer throws OutOfMemoryError with large max-messages

[ https://issues.apache.org/jira/browse/KAFKA-1980?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14335016#comment-14335016 ] Håkon Hitland commented on KAFKA-1980: -- I'm honestly not sure what to discuss, since

[jira] [Updated] (KAFKA-1980) Console consumer throws OutOfMemoryError with large max-messages

[ https://issues.apache.org/jira/browse/KAFKA-1980?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Håkon Hitland updated KAFKA-1980: - Attachment: kafka-1980.patch > Console consumer throws OutOfMemoryError with large max-messages >

Re: Review Request 31226: KAFKA-1615 Generating group ID in ZookeeperConsumerConnector shouldn't require local hostname to resolve

> On Feb. 24, 2015, 2:15 a.m., Gwen Shapira wrote: > > core/src/main/scala/kafka/consumer/ZookeeperConsumerConnector.scala, line > > 133 > > > > > > I think hostname will not be null because you set it to "localhost"

Re: Review Request 31226: KAFKA-1615 Generating group ID in ZookeeperConsumerConnector shouldn't require local hostname to resolve

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/31226/ --- (Updated Feb. 24, 2015, 3:12 p.m.) Review request for kafka. Changes ---

Re: Review Request 31226: KAFKA-1615 Generating group ID in ZookeeperConsumerConnector shouldn't require local hostname to resolve

> On Feb. 24, 2015, 2:15 a.m., Gwen Shapira wrote: > > core/src/main/scala/kafka/consumer/ZookeeperConsumerConnector.scala, line > > 133 > > > > > > I think hostname will not be null because you set it to "localhost"

Re: [DISCUSS] KIP-4 - Command line and centralized administrative operations

Hi all, I've updated KIP page, fixed / aligned document structure. Also I added some very initial proposal for AdminClient so we have something to start from while discussing the KIP. https://cwiki.apache.org/confluence/display/KAFKA/KIP-4+-+Command+line+and+centralized+administrative+operations