Re: Review Request 27684: Patch for KAFKA-1743

> On Nov. 18, 2014, 2:49 a.m., Jun Rao wrote: > > Thanks for the patch. Got the following compilation error. > > > > :core:compileTestScala/Users/junrao/intellij/kafka/core/src/test/scala/unit/kafka/consumer/ZookeeperConsumerConnectorTest.scala:116: > > overloaded method value commitOffsets wit

[jira] [Commented] (KAFKA-1743) ConsumerConnector.commitOffsets in 0.8.2 is not backward compatible

[ https://issues.apache.org/jira/browse/KAFKA-1743?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14215733#comment-14215733 ] Manikumar Reddy commented on KAFKA-1743: Updated reviewboard https://reviews.apach

[jira] [Updated] (KAFKA-1743) ConsumerConnector.commitOffsets in 0.8.2 is not backward compatible

[ https://issues.apache.org/jira/browse/KAFKA-1743?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar Reddy updated KAFKA-1743: --- Attachment: KAFKA-1743_2014-11-18_10:59:05.patch > ConsumerConnector.commitOffsets in 0.8.2 is

Re: Review Request 27684: Patch for KAFKA-1743

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/27684/ --- (Updated Nov. 18, 2014, 5:29 a.m.) Review request for kafka. Bugs: KAFKA-1743

[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=14215730#comment-14215730 ] Ashish Kumar Singh commented on KAFKA-1476: --- [~techybalaji] Left some comments o

Re: Review Request 27693: Patch for KAFKA-1476

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/27693/#review61873 --- Good work! Left some comments. core/src/main/scala/kafka/tools/Con

[jira] [Commented] (KAFKA-1773) Add a tool to check available consumer groups

[ https://issues.apache.org/jira/browse/KAFKA-1773?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14215716#comment-14215716 ] Ashish Kumar Singh commented on KAFKA-1773: --- [~nehanarkhede] thanks for pointing

[jira] [Commented] (KAFKA-1173) Using Vagrant to get up and running with Apache Kafka

[ https://issues.apache.org/jira/browse/KAFKA-1173?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14215675#comment-14215675 ] Joe Stein commented on KAFKA-1173: -- [~ewencp] changing override.hostmanager.ignore_privat

[jira] [Commented] (KAFKA-1173) Using Vagrant to get up and running with Apache Kafka

[ https://issues.apache.org/jira/browse/KAFKA-1173?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14215661#comment-14215661 ] Ewen Cheslack-Postava commented on KAFKA-1173: -- [~joestein] Got it, makes sen

[jira] [Updated] (KAFKA-1769) javadoc should only include client facing packages

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

Re: Review Request 27684: Patch for KAFKA-1743

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/27684/#review61863 --- Thanks for the patch. Got the following compilation error. :core:co

Re: Review Request 25995: Patch for KAFKA-1650

> On Nov. 17, 2014, 9:48 p.m., Guozhang Wang wrote: > > core/src/main/scala/kafka/tools/MirrorMaker.scala, line 338 > > > > > > Is it possible that the current chunk has been consumed completely and > > the fetcher th

[jira] [Commented] (KAFKA-1650) Mirror Maker could lose data on unclean shutdown.

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

[jira] [Updated] (KAFKA-1650) Mirror Maker could lose data on unclean shutdown.

[ https://issues.apache.org/jira/browse/KAFKA-1650?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin updated KAFKA-1650: Attachment: KAFKA-1650_2014-11-17_18:44:37.patch > Mirror Maker could lose data on unclean shutdown.

[jira] [Commented] (KAFKA-1173) Using Vagrant to get up and running with Apache Kafka

[ https://issues.apache.org/jira/browse/KAFKA-1173?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14215653#comment-14215653 ] Joe Stein commented on KAFKA-1173: -- [~ewencp] I agree no more toggles unless required. I

Re: Review Request 25995: Patch for KAFKA-1650

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/25995/ --- (Updated Nov. 18, 2014, 2:44 a.m.) Review request for kafka. Bugs: KAFKA-1650

[jira] [Commented] (KAFKA-1481) Stop using dashes AND underscores as separators in MBean names

[ https://issues.apache.org/jira/browse/KAFKA-1481?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14215645#comment-14215645 ] Jun Rao commented on KAFKA-1481: [~vladimir.tretyakov], thanks a lot for your work. Commit

[jira] [Commented] (KAFKA-1173) Using Vagrant to get up and running with Apache Kafka

[ https://issues.apache.org/jira/browse/KAFKA-1173?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14215639#comment-14215639 ] Ewen Cheslack-Postava commented on KAFKA-1173: -- You need ec2_associate_public

[jira] [Comment Edited] (KAFKA-1173) Using Vagrant to get up and running with Apache Kafka

[ https://issues.apache.org/jira/browse/KAFKA-1173?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14215589#comment-14215589 ] Joe Stein edited comment on KAFKA-1173 at 11/18/14 1:47 AM: [~

[jira] [Commented] (KAFKA-1173) Using Vagrant to get up and running with Apache Kafka

[ https://issues.apache.org/jira/browse/KAFKA-1173?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14215589#comment-14215589 ] Joe Stein commented on KAFKA-1173: -- [~ewencp] The aws parts are further along and servers

[jira] [Commented] (KAFKA-345) Add a listener to ZookeeperConsumerConnector to get notified on rebalance events

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

[jira] [Commented] (KAFKA-1634) Improve semantics of timestamp in OffsetCommitRequests and update documentation

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

[jira] [Updated] (KAFKA-345) Add a listener to ZookeeperConsumerConnector to get notified on rebalance events

[ https://issues.apache.org/jira/browse/KAFKA-345?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin updated KAFKA-345: --- Attachment: KAFKA-345_2014-11-17_17:42:42.patch > Add a listener to ZookeeperConsumerConnector to get n

[jira] [Updated] (KAFKA-1634) Improve semantics of timestamp in OffsetCommitRequests and update documentation

[ https://issues.apache.org/jira/browse/KAFKA-1634?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-1634: - Attachment: KAFKA-1634_2014-11-17_17:42:44.patch > Improve semantics of timestamp in OffsetCommitR

Re: Review Request 27990: Patch for KAFKA-1751

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/27990/#review61855 --- Ship it! Looks good! Two minor readability comments from my side, a

Re: Review Request 28025: Patch for KAFKA-345

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/28025/ --- (Updated Nov. 18, 2014, 1:42 a.m.) Review request for kafka. Bugs: KAFKA-345

Re: Review Request 27391: Fix KAFKA-1634

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/27391/ --- (Updated Nov. 18, 2014, 1:42 a.m.) Review request for kafka. Summary (updated

Re: Review Request 27391: Fix KAFKA-1634: Add the global retentionTime (in milis) and disable the per-offset timestamp

> On Nov. 7, 2014, 3 a.m., Joel Koshy wrote: > > core/src/main/scala/kafka/server/OffsetManager.scala, line 498 > > > > > > Actually, since we always set the retention period (for v0, v1) in > > KafkaApis do we need t

Re: Review Request 27391: Fix KAFKA-1634: Add the global retentionTime (in milis) and disable the per-offset timestamp

> On Nov. 17, 2014, 10:31 p.m., Joel Koshy wrote: > > clients/src/main/java/org/apache/kafka/common/requests/OffsetCommitRequest.java, > > line 151 > > > > > > Made a follow-up comment in the earlier RB. But pasting h

[jira] [Updated] (KAFKA-1173) Using Vagrant to get up and running with Apache Kafka

[ https://issues.apache.org/jira/browse/KAFKA-1173?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Joe Stein updated KAFKA-1173: - Fix Version/s: 0.8.3 > Using Vagrant to get up and running with Apache Kafka > ---

[jira] [Commented] (KAFKA-1173) Using Vagrant to get up and running with Apache Kafka

[ https://issues.apache.org/jira/browse/KAFKA-1173?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14215523#comment-14215523 ] Joe Stein commented on KAFKA-1173: -- ignore last issue I quoted everything and spinni

[jira] [Commented] (KAFKA-1173) Using Vagrant to get up and running with Apache Kafka

[ https://issues.apache.org/jira/browse/KAFKA-1173?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14215515#comment-14215515 ] Joe Stein commented on KAFKA-1173: -- FYI - trying a new AWS secret key but got error becau

[jira] [Updated] (KAFKA-1773) Add a tool to check available consumer groups

[ https://issues.apache.org/jira/browse/KAFKA-1773?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-1773: - Resolution: Duplicate Status: Resolved (was: Patch Available) > Add a tool to check avail

[jira] [Commented] (KAFKA-1773) Add a tool to check available consumer groups

[ https://issues.apache.org/jira/browse/KAFKA-1773?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14215506#comment-14215506 ] Neha Narkhede commented on KAFKA-1773: -- Thanks for the patch. The plan is to instead

[jira] [Commented] (KAFKA-1624) building on JDK 8 fails

[ https://issues.apache.org/jira/browse/KAFKA-1624?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14215420#comment-14215420 ] Ewen Cheslack-Postava commented on KAFKA-1624: -- Isn't 2.10.4 the latest versi

[jira] [Commented] (KAFKA-1481) Stop using dashes AND underscores as separators in MBean names

[ https://issues.apache.org/jira/browse/KAFKA-1481?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14215371#comment-14215371 ] Joel Koshy commented on KAFKA-1481: --- +1 (for 0.8.2) > Stop using dashes AND underscore

How to recover from ConsumerRebalanceFailedException ?

Hi Kafka Team, I get following exception due to ZK/Network issues intermittently. How do I recover from consumer thread dying *programmatically* and restart source because we have alerts that due to this error we have partition OWNERSHIP is *none* ? Please let me know how to restart source and

Re: Review Request 27391: Fix KAFKA-1634: Add the global retentionTime (in milis) and disable the per-offset timestamp

> On Nov. 7, 2014, 3 a.m., Joel Koshy wrote: > > clients/src/main/java/org/apache/kafka/common/requests/OffsetCommitRequest.java, > > line 152 > > > > > > This confused me a bit, and I think it is because initCommonFi

Re: Review Request 27391: Fix KAFKA-1634: Add the global retentionTime (in milis) and disable the per-offset timestamp

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/27391/#review61761 --- clients/src/main/java/org/apache/kafka/common/requests/OffsetCommit

[jira] [Commented] (KAFKA-1481) Stop using dashes AND underscores as separators in MBean names

[ https://issues.apache.org/jira/browse/KAFKA-1481?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14215304#comment-14215304 ] Jun Rao commented on KAFKA-1481: Thanks for the patch. +1 from me. Just a few minor commen

[jira] [Commented] (KAFKA-1624) building on JDK 8 fails

[ https://issues.apache.org/jira/browse/KAFKA-1624?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14215288#comment-14215288 ] Guozhang Wang commented on KAFKA-1624: -- Thanks Joe. So I will bump up the default ver

Re: Review Request 25995: Patch for KAFKA-1650

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/25995/#review61528 --- core/src/main/scala/kafka/tools/MirrorMaker.scala

[jira] [Updated] (KAFKA-1771) replicate_testsuite data verification broken if num_partitions > replica_factor

[ https://issues.apache.org/jira/browse/KAFKA-1771?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-1771: - Attachment: kafka-1771.wip.patch [~becket_qin], I'm attaching the WIP patch I crea

[jira] [Commented] (KAFKA-1781) Readme should specify that Gradle 2.0 is required for initial bootstrap

[ https://issues.apache.org/jira/browse/KAFKA-1781?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14215079#comment-14215079 ] Jean-Francois Im commented on KAFKA-1781: - Also, see https://issues.gradle.org/bro

[jira] [Commented] (KAFKA-1781) Readme should specify that Gradle 2.0 is required for initial bootstrap

[ https://issues.apache.org/jira/browse/KAFKA-1781?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14215074#comment-14215074 ] Jean-Francois Im commented on KAFKA-1781: - I think the two are related to JDK 8, b

[jira] [Commented] (KAFKA-1771) replicate_testsuite data verification broken if num_partitions > replica_factor

[ https://issues.apache.org/jira/browse/KAFKA-1771?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14215065#comment-14215065 ] Jiangjie Qin commented on KAFKA-1771: - Hi Ewen, have you got a chance to work on this?

[jira] [Comment Edited] (KAFKA-1771) replicate_testsuite data verification broken if num_partitions > replica_factor

[ https://issues.apache.org/jira/browse/KAFKA-1771?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14215065#comment-14215065 ] Jiangjie Qin edited comment on KAFKA-1771 at 11/17/14 7:50 PM: -

[jira] [Commented] (KAFKA-1781) Readme should specify that Gradle 2.0 is required for initial bootstrap

[ https://issues.apache.org/jira/browse/KAFKA-1781?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14215040#comment-14215040 ] Joe Stein commented on KAFKA-1781: -- JDK 8 related support information is captured here KA

[jira] [Commented] (KAFKA-1781) Readme should specify that Gradle 2.0 is required for initial bootstrap

[ https://issues.apache.org/jira/browse/KAFKA-1781?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14215036#comment-14215036 ] Jean-Francois Im commented on KAFKA-1781: - It seems to work with 1.8 and 1.12 if I

[jira] [Commented] (KAFKA-1781) Readme should specify that Gradle 2.0 is required for initial bootstrap

[ https://issues.apache.org/jira/browse/KAFKA-1781?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14215030#comment-14215030 ] Joe Stein commented on KAFKA-1781: -- I think your issue is related to your JVM being 8 ins

[jira] [Commented] (KAFKA-1781) Readme should specify that Gradle 2.0 is required for initial bootstrap

[ https://issues.apache.org/jira/browse/KAFKA-1781?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14215013#comment-14215013 ] Jean-Francois Im commented on KAFKA-1781: - It is weird! This is what I get: {quot

[jira] [Commented] (KAFKA-1781) Readme should specify that Gradle 2.0 is required for initial bootstrap

[ https://issues.apache.org/jira/browse/KAFKA-1781?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14214978#comment-14214978 ] Joe Stein commented on KAFKA-1781: -- That is weird, I tried from a fresh clone just now {

Re: Review Request 28025: Patch for KAFKA-345

> On Nov. 14, 2014, 11:36 p.m., Joel Koshy wrote: > > core/src/main/scala/kafka/javaapi/consumer/ConsumerRebalanceListener.java, > > line 29 > > > > > > It would be worth elaborating the use-case for these hooks (i.e.,

[jira] [Commented] (KAFKA-1781) Readme should specify that Gradle 2.0 is required for initial bootstrap

[ https://issues.apache.org/jira/browse/KAFKA-1781?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14214969#comment-14214969 ] Jean-Francois Im commented on KAFKA-1781: - It doesn't seem to work with 1.8. {quo

[jira] [Comment Edited] (KAFKA-1624) building on JDK 8 fails

[ https://issues.apache.org/jira/browse/KAFKA-1624?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14214956#comment-14214956 ] Joe Stein edited comment on KAFKA-1624 at 11/17/14 6:30 PM: <<

[jira] [Comment Edited] (KAFKA-1624) building on JDK 8 fails

[ https://issues.apache.org/jira/browse/KAFKA-1624?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14214956#comment-14214956 ] Joe Stein edited comment on KAFKA-1624 at 11/17/14 6:30 PM: <<

[jira] [Commented] (KAFKA-1624) building on JDK 8 fails

[ https://issues.apache.org/jira/browse/KAFKA-1624?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14214956#comment-14214956 ] Joe Stein commented on KAFKA-1624: -- << I did some tests locally with various Scala versio

[jira] [Reopened] (KAFKA-1624) building on JDK 8 fails

[ https://issues.apache.org/jira/browse/KAFKA-1624?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Joe Stein reopened KAFKA-1624: -- > building on JDK 8 fails > --- > > Key: KAFKA-1624 > UR

[jira] [Updated] (KAFKA-1624) building on JDK 8 fails

[ https://issues.apache.org/jira/browse/KAFKA-1624?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Joe Stein updated KAFKA-1624: - Fix Version/s: (was: 0.9.0) 0.8.2 > building on JDK 8 fails > -

[jira] [Commented] (KAFKA-1781) Readme should specify that Gradle 2.0 is required for initial bootstrap

[ https://issues.apache.org/jira/browse/KAFKA-1781?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14214951#comment-14214951 ] Joe Stein commented on KAFKA-1781: -- [~jean-francois.l...@teximus.com] I have this working

Re: Review Request 28040: Patch for KAFKA-1770

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/28040/#review61751 --- UnknownTopicOrPartitionException can be thrown either at the produce

[jira] [Updated] (KAFKA-1781) Readme should specify that Gradle 2.0 is required for initial bootstrap

[ https://issues.apache.org/jira/browse/KAFKA-1781?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jean-Francois Im updated KAFKA-1781: Attachment: gradle-2.0-readme.patch Documentation patch that changes README.md to say "You n

[jira] [Updated] (KAFKA-1781) Readme should specify that Gradle 2.0 is required for initial bootstrap

[ https://issues.apache.org/jira/browse/KAFKA-1781?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Joe Stein updated KAFKA-1781: - Priority: Blocker (was: Trivial) > Readme should specify that Gradle 2.0 is required for initial bootstra

[jira] [Updated] (KAFKA-1781) Readme should specify that Gradle 2.0 is required for initial bootstrap

[ https://issues.apache.org/jira/browse/KAFKA-1781?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Joe Stein updated KAFKA-1781: - Fix Version/s: 0.8.2 > Readme should specify that Gradle 2.0 is required for initial bootstrap > -

[jira] [Created] (KAFKA-1781) Readme should specify that Gradle 2.0 is required for initial bootstrap

Jean-Francois Im created KAFKA-1781: --- Summary: Readme should specify that Gradle 2.0 is required for initial bootstrap Key: KAFKA-1781 URL: https://issues.apache.org/jira/browse/KAFKA-1781 Project:

Re: Support for topics+streams at class WildcardStreamsHandler

Just added an entry in the FAQ page: https://cwiki.apache.org/confluence/display/KAFKA/FAQ#FAQ-Whycan%27tIspecifythenumberofstreamsparallelismpertopicmapusingwildcardstreamasIusestaticstreamhandler ? On Mon, Nov 10, 2014 at 7:56 AM, Guozhang Wang wrote: > Hi Alan, > > The reason we do not have

[jira] [Commented] (KAFKA-1780) Add peek()/poll() for ConsumerIterator

[ https://issues.apache.org/jira/browse/KAFKA-1780?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14214897#comment-14214897 ] Ewen Cheslack-Postava commented on KAFKA-1780: -- Patch attached adds a NonBloc

[jira] [Updated] (KAFKA-1780) Add peek()/poll() for ConsumerIterator

[ https://issues.apache.org/jira/browse/KAFKA-1780?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-1780: - Reviewer: Jun Rao > Add peek()/poll() for ConsumerIterator > -

[jira] [Commented] (KAFKA-1780) Add peek()/poll() for ConsumerIterator

[ https://issues.apache.org/jira/browse/KAFKA-1780?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14214888#comment-14214888 ] Ewen Cheslack-Postava commented on KAFKA-1780: -- Created reviewboard https://r

[jira] [Updated] (KAFKA-1780) Add peek()/poll() for ConsumerIterator

[ https://issues.apache.org/jira/browse/KAFKA-1780?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-1780: - Status: Patch Available (was: Open) > Add peek()/poll() for ConsumerIterator > --

[jira] [Updated] (KAFKA-1780) Add peek()/poll() for ConsumerIterator

[ https://issues.apache.org/jira/browse/KAFKA-1780?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-1780: - Attachment: KAFKA-1780.patch > Add peek()/poll() for ConsumerIterator > --

Review Request 28121: Patch for KAFKA-1780

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

[jira] [Created] (KAFKA-1780) Add peek()/poll() for ConsumerIterator

Ewen Cheslack-Postava created KAFKA-1780: Summary: Add peek()/poll() for ConsumerIterator Key: KAFKA-1780 URL: https://issues.apache.org/jira/browse/KAFKA-1780 Project: Kafka Issue Ty

Re: Kafka Simple Consumer API for 0.9

Hi Dibyendu, Yes we are changing the consumer API in 0.9, which will be different with the current high-level consumer API. We are also trying to figure out a way to preserve the functionality: KAFKA-1655 Guozhang On Fri, Nov 14, 2014 at 5:29 PM

[jira] [Commented] (KAFKA-1779) FetchRequest.maxWait has no effect

[ https://issues.apache.org/jira/browse/KAFKA-1779?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14214841#comment-14214841 ] Guozhang Wang commented on KAFKA-1779: -- Hi Magnus, The semantics of maxWait is not f

[jira] [Updated] (KAFKA-1772) Add an Admin message type for request response

[ https://issues.apache.org/jira/browse/KAFKA-1772?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Joe Stein updated KAFKA-1772: - Description: - utility int8 - command int8 - format int8 - args variable length bytes utility 0 - Broker

[jira] [Updated] (KAFKA-1772) Add an Admin message type for request response

[ https://issues.apache.org/jira/browse/KAFKA-1772?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Joe Stein updated KAFKA-1772: - Reviewer: Joe Stein > Add an Admin message type for request response > ---

[jira] [Updated] (KAFKA-1772) Add an Admin message type for request response

[ https://issues.apache.org/jira/browse/KAFKA-1772?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Joe Stein updated KAFKA-1772: - Assignee: Andrii Biletskyi > Add an Admin message type for request response >

[jira] [Updated] (KAFKA-1772) Add an Admin message type for request response

[ https://issues.apache.org/jira/browse/KAFKA-1772?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Joe Stein updated KAFKA-1772: - Assignee: (was: Joe Stein) > Add an Admin message type for request response >

[jira] [Assigned] (KAFKA-1772) Add an Admin message type for request response

[ https://issues.apache.org/jira/browse/KAFKA-1772?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Joe Stein reassigned KAFKA-1772: Assignee: Joe Stein > Add an Admin message type for request response >

[jira] [Commented] (KAFKA-1173) Using Vagrant to get up and running with Apache Kafka

[ https://issues.apache.org/jira/browse/KAFKA-1173?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14214748#comment-14214748 ] Joe Stein commented on KAFKA-1173: -- I haven't had a chance to review the last changes for

[jira] [Updated] (KAFKA-1751) handle "broker not exists" and "topic not exists" scenarios

[ https://issues.apache.org/jira/browse/KAFKA-1751?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dmitry Pekar updated KAFKA-1751: Attachment: KAFKA-1751_2014-11-17_16:33:43.patch > handle "broker not exists" and "topic not exists"

[jira] [Commented] (KAFKA-1751) handle "broker not exists" and "topic not exists" scenarios

[ https://issues.apache.org/jira/browse/KAFKA-1751?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14214694#comment-14214694 ] Dmitry Pekar commented on KAFKA-1751: - Updated reviewboard https://reviews.apache.org/

Re: Review Request 27990: Patch for KAFKA-1751

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/27990/ --- (Updated Nov. 17, 2014, 2:33 p.m.) Review request for kafka. Bugs: KAFKA-1751

[jira] [Updated] (KAFKA-1751) handle "broker not exists" and "topic not exists" scenarios

[ https://issues.apache.org/jira/browse/KAFKA-1751?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dmitry Pekar updated KAFKA-1751: Attachment: KAFKA-1751_2014-11-17_16:25:14.patch > handle "broker not exists" and "topic not exists"

[jira] [Commented] (KAFKA-1751) handle "broker not exists" and "topic not exists" scenarios

[ https://issues.apache.org/jira/browse/KAFKA-1751?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14214687#comment-14214687 ] Dmitry Pekar commented on KAFKA-1751: - Updated reviewboard https://reviews.apache.org/

Re: Review Request 27990: Patch for KAFKA-1751

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/27990/ --- (Updated Nov. 17, 2014, 2:25 p.m.) Review request for kafka. Bugs: KAFKA-1751

[jira] [Comment Edited] (KAFKA-1481) Stop using dashes AND underscores as separators in MBean names

[ https://issues.apache.org/jira/browse/KAFKA-1481?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14214559#comment-14214559 ] Vladimir Tretyakov edited comment on KAFKA-1481 at 11/17/14 11:52 AM: --

[jira] [Commented] (KAFKA-1481) Stop using dashes AND underscores as separators in MBean names

[ https://issues.apache.org/jira/browse/KAFKA-1481?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14214559#comment-14214559 ] Vladimir Tretyakov commented on KAFKA-1481: --- Hi, provided new patch, last one?:)

[jira] [Updated] (KAFKA-1481) Stop using dashes AND underscores as separators in MBean names

[ https://issues.apache.org/jira/browse/KAFKA-1481?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vladimir Tretyakov updated KAFKA-1481: -- Attachment: KAFKA-1481_2014-11-17_14-33-03.patch > Stop using dashes AND underscores as

[jira] [Created] (KAFKA-1779) FetchRequest.maxWait has no effect

Magnus Vojbacke created KAFKA-1779: -- Summary: FetchRequest.maxWait has no effect Key: KAFKA-1779 URL: https://issues.apache.org/jira/browse/KAFKA-1779 Project: Kafka Issue Type: Bug