[jira] [Commented] (KAFKA-1326) New consumer checklist

[ https://issues.apache.org/jira/browse/KAFKA-1326?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14059535#comment-14059535 ] Jay Kreps commented on KAFKA-1326: -- Hey [~nmarasoi] there are some docs on the plans here

[jira] [Commented] (KAFKA-1112) broker can not start itself after kafka is killed with -9

[ https://issues.apache.org/jira/browse/KAFKA-1112?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14059533#comment-14059533 ] Alexis Midon commented on KAFKA-1112: - Hello, I suffered from the same error using Ka

[jira] [Comment Edited] (KAFKA-1300) Added WaitForReplaction admin tool.

[ https://issues.apache.org/jira/browse/KAFKA-1300?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14059512#comment-14059512 ] Alexis Midon edited comment on KAFKA-1300 at 7/11/14 11:47 PM: -

[jira] [Comment Edited] (KAFKA-1300) Added WaitForReplaction admin tool.

[ https://issues.apache.org/jira/browse/KAFKA-1300?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14059512#comment-14059512 ] Alexis Midon edited comment on KAFKA-1300 at 7/11/14 11:46 PM: -

[jira] [Commented] (KAFKA-1300) Added WaitForReplaction admin tool.

[ https://issues.apache.org/jira/browse/KAFKA-1300?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14059512#comment-14059512 ] Alexis Midon commented on KAFKA-1300: - Consiering that Kafka is designed to handle som

[jira] [Commented] (KAFKA-1537) add request.required.acks=-2 to require acks from all replicas

[ https://issues.apache.org/jira/browse/KAFKA-1537?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14059451#comment-14059451 ] Jay Kreps commented on KAFKA-1537: -- Wouldn't it be somewhat odd that you actually want to

Build failed in Jenkins: Kafka-trunk #220

See Changes: [jay.kreps] KAFKA-1515 Producer can hang during metadata updates. Patch by Guozhang. -- [...truncated 1772 lines...] java.net.BindException: Address already in use at sun.nio

[jira] [Created] (KAFKA-1537) add request.required.acks=-2 to require acks from all replicas

Jiang Wu created KAFKA-1537: --- Summary: add request.required.acks=-2 to require acks from all replicas Key: KAFKA-1537 URL: https://issues.apache.org/jira/browse/KAFKA-1537 Project: Kafka Issue Typ

[jira] [Commented] (KAFKA-1535) return all live brokers in TopicMetadataResponse

[ https://issues.apache.org/jira/browse/KAFKA-1535?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14059287#comment-14059287 ] Jay Kreps commented on KAFKA-1535: -- Yes I think that is correct. The current behavior is

[jira] [Commented] (KAFKA-1515) Wake-up Sender upon blocked on fetching leader metadata

[ https://issues.apache.org/jira/browse/KAFKA-1515?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14059286#comment-14059286 ] Jay Kreps commented on KAFKA-1515: -- Committed with a very minor change: I renamed the isR

[jira] [Commented] (KAFKA-1515) Wake-up Sender upon blocked on fetching leader metadata

[ https://issues.apache.org/jira/browse/KAFKA-1515?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14059269#comment-14059269 ] Jay Kreps commented on KAFKA-1515: -- I am getting transient hangs after ProducerFailureTes

[jira] [Comment Edited] (KAFKA-1326) New consumer checklist

[ https://issues.apache.org/jira/browse/KAFKA-1326?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14059216#comment-14059216 ] nicu marasoiu edited comment on KAFKA-1326 at 7/11/14 7:24 PM: -

[jira] [Comment Edited] (KAFKA-1326) New consumer checklist

[ https://issues.apache.org/jira/browse/KAFKA-1326?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14059216#comment-14059216 ] nicu marasoiu edited comment on KAFKA-1326 at 7/11/14 7:21 PM: -

[jira] [Commented] (KAFKA-1330) Implement subscribe(TopicPartition...partitions) in the new consumer

[ https://issues.apache.org/jira/browse/KAFKA-1330?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14059221#comment-14059221 ] nicu marasoiu commented on KAFKA-1330: -- Hi, If I want to take this, how much time to

[jira] [Commented] (KAFKA-1326) New consumer checklist

[ https://issues.apache.org/jira/browse/KAFKA-1326?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14059216#comment-14059216 ] nicu marasoiu commented on KAFKA-1326: -- Hey guys, What can I take from the unassigne

[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=14059209#comment-14059209 ] nicu marasoiu commented on KAFKA-1476: -- if you just browse zookeeper with some standa

[jira] [Commented] (KAFKA-1535) return all live brokers in TopicMetadataResponse

[ https://issues.apache.org/jira/browse/KAFKA-1535?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14059203#comment-14059203 ] nicu marasoiu commented on KAFKA-1535: -- So what I understand from the issue: the topi

[jira] [Commented] (KAFKA-1535) return all live brokers in TopicMetadataResponse

[ https://issues.apache.org/jira/browse/KAFKA-1535?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14059200#comment-14059200 ] Jay Kreps commented on KAFKA-1535: -- Cool, go for it. Just attach a patch to this issue an

[jira] [Commented] (KAFKA-1535) return all live brokers in TopicMetadataResponse

[ https://issues.apache.org/jira/browse/KAFKA-1535?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14059188#comment-14059188 ] nicu marasoiu commented on KAFKA-1535: -- Hi, I am a 11 years java developer and gradu

[jira] [Commented] (KAFKA-1040) ConsumerConfig and ProducerConfig do "work" in the Constructor

[ https://issues.apache.org/jira/browse/KAFKA-1040?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14059175#comment-14059175 ] Jay Kreps commented on KAFKA-1040: -- Not sure I get the analogy, can we be concrete about

[jira] [Comment Edited] (KAFKA-1040) ConsumerConfig and ProducerConfig do "work" in the Constructor

[ https://issues.apache.org/jira/browse/KAFKA-1040?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14059165#comment-14059165 ] Sharmarke Aden edited comment on KAFKA-1040 at 7/11/14 6:37 PM:

[jira] [Commented] (KAFKA-1040) ConsumerConfig and ProducerConfig do "work" in the Constructor

[ https://issues.apache.org/jira/browse/KAFKA-1040?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14059165#comment-14059165 ] Sharmarke Aden commented on KAFKA-1040: --- Suppose you want to build your dream house

[jira] [Commented] (KAFKA-1533) transient unit test failure in ProducerFailureHandlingTest

[ https://issues.apache.org/jira/browse/KAFKA-1533?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14059160#comment-14059160 ] Guozhang Wang commented on KAFKA-1533: -- I think at least one thing we can do to impro

[jira] [Commented] (KAFKA-1533) transient unit test failure in ProducerFailureHandlingTest

[ https://issues.apache.org/jira/browse/KAFKA-1533?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14059146#comment-14059146 ] Jun Rao commented on KAFKA-1533: Not sure. The test itself is done and all left is the tea

Re: Review Request 21588: Fix KAFKA-1430: Purgatory Redesign

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/21588/ --- (Updated July 11, 2014, 6:07 p.m.) Review request for kafka. Summary (updated

[jira] [Updated] (KAFKA-1430) Purgatory redesign

[ https://issues.apache.org/jira/browse/KAFKA-1430?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-1430: - Attachment: KAFKA-1430_2014-07-11_10:59:13.patch > Purgatory redesign > -- > >

[jira] [Commented] (KAFKA-1430) Purgatory redesign

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

Re: Review Request 21588: Fix KAFKA-1515

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/21588/ --- (Updated July 11, 2014, 5:59 p.m.) Review request for kafka. Summary (updated

[jira] [Commented] (KAFKA-1040) ConsumerConfig and ProducerConfig do "work" in the Constructor

[ https://issues.apache.org/jira/browse/KAFKA-1040?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14059095#comment-14059095 ] Jay Kreps commented on KAFKA-1040: -- Hey guys, I'm not sure I agree with this principle. T

[jira] [Resolved] (KAFKA-1026) Dynamically Adjust Batch Size Upon Receiving MessageSizeTooLargeException

[ https://issues.apache.org/jira/browse/KAFKA-1026?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jay Kreps resolved KAFKA-1026. -- Resolution: Fixed Fix Version/s: (was: 0.9.0) 0.8.2 Cool, closing with fi

[jira] [Created] (KAFKA-1536) Change the status of the JIRA to "Patch Available" in the kafka-review-tool

Guozhang Wang created KAFKA-1536: Summary: Change the status of the JIRA to "Patch Available" in the kafka-review-tool Key: KAFKA-1536 URL: https://issues.apache.org/jira/browse/KAFKA-1536 Project: Ka

[jira] [Commented] (KAFKA-1531) zookeeper.connection.timeout.ms is set to 10000000 in configuration file in Kafka tarball

[ https://issues.apache.org/jira/browse/KAFKA-1531?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14059058#comment-14059058 ] Manikumar Reddy commented on KAFKA-1531: The following properties updated in serv

[jira] [Commented] (KAFKA-1531) zookeeper.connection.timeout.ms is set to 10000000 in configuration file in Kafka tarball

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

[jira] [Updated] (KAFKA-1531) zookeeper.connection.timeout.ms is set to 10000000 in configuration file in Kafka tarball

[ https://issues.apache.org/jira/browse/KAFKA-1531?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar Reddy updated KAFKA-1531: --- Attachment: KAFKA-1531.patch > zookeeper.connection.timeout.ms is set to 1000 in configur

Review Request 23417: Patch for KAFKA-1531

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

[jira] [Commented] (KAFKA-1026) Dynamically Adjust Batch Size Upon Receiving MessageSizeTooLargeException

[ https://issues.apache.org/jira/browse/KAFKA-1026?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14059050#comment-14059050 ] Guozhang Wang commented on KAFKA-1026: -- There is a rare case when we can still hit th

[jira] [Commented] (KAFKA-1026) Dynamically Adjust Batch Size Upon Receiving MessageSizeTooLargeException

[ https://issues.apache.org/jira/browse/KAFKA-1026?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14059044#comment-14059044 ] Jay Kreps commented on KAFKA-1026: -- I believe this is fixed in the new producer, no? We w

[jira] [Updated] (KAFKA-1026) Dynamically Adjust Batch Size Upon Receiving MessageSizeTooLargeException

[ https://issues.apache.org/jira/browse/KAFKA-1026?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-1026: - Labels: newbie++ (was: ) > Dynamically Adjust Batch Size Upon Receiving MessageSizeTooLargeExcep

[jira] [Resolved] (KAFKA-1067) the default partitioner should be randomizing messages and a new partition for the meta refresh requirements created

[ https://issues.apache.org/jira/browse/KAFKA-1067?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-1067. -- Resolution: Fixed > the default partitioner should be randomizing messages and a new partition

[jira] [Updated] (KAFKA-1040) ConsumerConfig and ProducerConfig do "work" in the Constructor

[ https://issues.apache.org/jira/browse/KAFKA-1040?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-1040: - Labels: config newbie (was: config) > ConsumerConfig and ProducerConfig do "work" in the Constru

[jira] [Updated] (KAFKA-1258) Delete temporary data directory after unit test finishes

[ https://issues.apache.org/jira/browse/KAFKA-1258?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-1258: - Labels: newbie (was: ) > Delete temporary data directory after unit test finishes >

[jira] [Updated] (KAFKA-1386) Configs in SystemTest's generate_overriden_props_files are hard-coded

[ https://issues.apache.org/jira/browse/KAFKA-1386?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-1386: - Labels: newbie++ (was: ) > Configs in SystemTest's generate_overriden_props_files are hard-coded

[jira] [Updated] (KAFKA-1282) Disconnect idle socket connection in Selector

[ https://issues.apache.org/jira/browse/KAFKA-1282?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-1282: - Labels: newbie++ (was: ) > Disconnect idle socket connection in Selector > -

[jira] [Commented] (KAFKA-1533) transient unit test failure in ProducerFailureHandlingTest

[ https://issues.apache.org/jira/browse/KAFKA-1533?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14059021#comment-14059021 ] Guozhang Wang commented on KAFKA-1533: -- Maybe memory usage can be reduced, which test

[jira] [Updated] (KAFKA-1515) Wake-up Sender upon blocked on fetching leader metadata

[ https://issues.apache.org/jira/browse/KAFKA-1515?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-1515: - Attachment: KAFKA-1515.patch > Wake-up Sender upon blocked on fetching leader metadata >

[jira] [Commented] (KAFKA-1515) Wake-up Sender upon blocked on fetching leader metadata

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

Review Request 23415: Follow-up KAFKA-1515

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

[jira] [Commented] (KAFKA-1535) return all live brokers in TopicMetadataResponse

[ https://issues.apache.org/jira/browse/KAFKA-1535?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14058949#comment-14058949 ] Jun Rao commented on KAFKA-1535: A solution is to return all live brokers (in metadata cac

[jira] [Created] (KAFKA-1535) return all live brokers in TopicMetadataResponse

Jun Rao created KAFKA-1535: -- Summary: return all live brokers in TopicMetadataResponse Key: KAFKA-1535 URL: https://issues.apache.org/jira/browse/KAFKA-1535 Project: Kafka Issue Type: Improvement

[jira] [Commented] (KAFKA-1471) Add Producer Unit Tests for LZ4 and LZ4HC compression

[ https://issues.apache.org/jira/browse/KAFKA-1471?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14058908#comment-14058908 ] Jun Rao commented on KAFKA-1471: Sorry for the late review. The patch doesn't seem to appl

[jira] [Commented] (KAFKA-1530) howto update continuously

[ https://issues.apache.org/jira/browse/KAFKA-1530?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14058893#comment-14058893 ] Jun Rao commented on KAFKA-1530: We do have an option "unclean.leader.election.enable" to

[jira] [Commented] (KAFKA-1531) zookeeper.connection.timeout.ms is set to 10000000 in configuration file in Kafka tarball

[ https://issues.apache.org/jira/browse/KAFKA-1531?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14058878#comment-14058878 ] Jun Rao commented on KAFKA-1531: Yes, it would be good to clean those up too. We can just

[jira] [Commented] (KAFKA-1406) Fix scaladoc/javadoc warnings

[ https://issues.apache.org/jira/browse/KAFKA-1406?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14058877#comment-14058877 ] Alan Lee commented on KAFKA-1406: - Great. Thanks for handling that quickly. Now I'll go an

Re: Review Request 23396: Patch for KAFKA-1531

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/23396/#review47650 --- system_test/replication_testsuite/config/server.properties

[jira] [Resolved] (KAFKA-1361) enable controlled shutdown by default

[ https://issues.apache.org/jira/browse/KAFKA-1361?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao resolved KAFKA-1361. Resolution: Duplicate Duplicate of KAFKA-1298. > enable controlled shutdown by default > -

[jira] [Commented] (KAFKA-1533) transient unit test failure in ProducerFailureHandlingTest

[ https://issues.apache.org/jira/browse/KAFKA-1533?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14058853#comment-14058853 ] Jun Rao commented on KAFKA-1533: Yes, I am not sure what the issue is. Occasionally, I do

[jira] [Comment Edited] (KAFKA-1530) howto update continuously

[ https://issues.apache.org/jira/browse/KAFKA-1530?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14058568#comment-14058568 ] Andrey Stepachev edited comment on KAFKA-1530 at 7/11/14 9:00 AM: --

[jira] [Commented] (KAFKA-1530) howto update continuously

[ https://issues.apache.org/jira/browse/KAFKA-1530?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14058568#comment-14058568 ] Andrey Stepachev commented on KAFKA-1530: - Looks like [~ovgolovin] problem with wr

[jira] [Comment Edited] (KAFKA-1530) howto update continuously

[ https://issues.apache.org/jira/browse/KAFKA-1530?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14058568#comment-14058568 ] Andrey Stepachev edited comment on KAFKA-1530 at 7/11/14 9:00 AM: --

[jira] [Comment Edited] (KAFKA-1531) zookeeper.connection.timeout.ms is set to 10000000 in configuration file in Kafka tarball

[ https://issues.apache.org/jira/browse/KAFKA-1531?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14058555#comment-14058555 ] Manikumar Reddy edited comment on KAFKA-1531 at 7/11/14 8:43 AM: ---

[jira] [Commented] (KAFKA-1531) zookeeper.connection.timeout.ms is set to 10000000 in configuration file in Kafka tarball

[ https://issues.apache.org/jira/browse/KAFKA-1531?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14058555#comment-14058555 ] Manikumar Reddy commented on KAFKA-1531: I feel some of the important tunable para