Re: Review Request 28769: Patch for KAFKA-1809

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/28769/ --- (Updated Dec. 29, 2014, 8:11 p.m.) Review request for kafka. Bugs:

[jira] [Commented] (KAFKA-1809) Refactor brokers to allow listening on multiple ports and IPs

[ https://issues.apache.org/jira/browse/KAFKA-1809?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14260396#comment-14260396 ] Gwen Shapira commented on KAFKA-1809: - Updated reviewboard

[jira] [Updated] (KAFKA-1809) Refactor brokers to allow listening on multiple ports and IPs

[ https://issues.apache.org/jira/browse/KAFKA-1809?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira updated KAFKA-1809: Attachment: KAFKA-1809_2014-12-29_12:11:36.patch Refactor brokers to allow listening on multiple

[jira] [Created] (KAFKA-1835) Kafka new producer needs options to make blocking behavior explicit

Paul Pearcy created KAFKA-1835: -- Summary: Kafka new producer needs options to make blocking behavior explicit Key: KAFKA-1835 URL: https://issues.apache.org/jira/browse/KAFKA-1835 Project: Kafka

[jira] [Created] (KAFKA-1836) metadata.fetch.timeout.ms set to zero blocks forever

Paul Pearcy created KAFKA-1836: -- Summary: metadata.fetch.timeout.ms set to zero blocks forever Key: KAFKA-1836 URL: https://issues.apache.org/jira/browse/KAFKA-1836 Project: Kafka Issue Type:

[jira] [Created] (KAFKA-1837) Metadata record future never returns on get call after producer is stopped and messages can't be sent

Paul Pearcy created KAFKA-1837: -- Summary: Metadata record future never returns on get call after producer is stopped and messages can't be sent Key: KAFKA-1837 URL: https://issues.apache.org/jira/browse/KAFKA-1837

[jira] [Updated] (KAFKA-1790) Remote controlled shutdown was removed

[ https://issues.apache.org/jira/browse/KAFKA-1790?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-1790: - Priority: Major (was: Blocker) Bumping this down to not be a blocker. Remote controlled

[jira] [Commented] (KAFKA-1782) Junit3 Misusage

[ https://issues.apache.org/jira/browse/KAFKA-1782?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14260475#comment-14260475 ] Neha Narkhede commented on KAFKA-1782: -- [~guozhang], [~jjkoshy] It looks like we can

[jira] [Commented] (KAFKA-1785) Consumer offset checker should show the offset manager and offsets partition

[ https://issues.apache.org/jira/browse/KAFKA-1785?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14260476#comment-14260476 ] Neha Narkhede commented on KAFKA-1785: -- This looks like something that can be pushed

[jira] [Updated] (KAFKA-1836) metadata.fetch.timeout.ms set to zero blocks forever

[ https://issues.apache.org/jira/browse/KAFKA-1836?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jay Kreps updated KAFKA-1836: - Labels: newbie (was: ) metadata.fetch.timeout.ms set to zero blocks forever

Re: Review Request 29210: Patch for KAFKA-1819

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/29210/#review66307 --- core/src/test/scala/unit/kafka/log/LogCleanerIntegrationTest.scala

[jira] [Commented] (KAFKA-1819) Cleaner gets confused about deleted and re-created topics

[ https://issues.apache.org/jira/browse/KAFKA-1819?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14260482#comment-14260482 ] Neha Narkhede commented on KAFKA-1819: -- [~gwenshap] Thanks for the updated patch!

[jira] [Commented] (KAFKA-1836) metadata.fetch.timeout.ms set to zero blocks forever

[ https://issues.apache.org/jira/browse/KAFKA-1836?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14260483#comment-14260483 ] Jay Kreps commented on KAFKA-1836: -- Looks like Metadata.awaitUpdate() always calls

[jira] [Commented] (KAFKA-1784) Implement a ConsumerOffsetClient library

[ https://issues.apache.org/jira/browse/KAFKA-1784?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14260484#comment-14260484 ] Neha Narkhede commented on KAFKA-1784: -- [~mgharat] Did you get a chance to address my

[jira] [Commented] (KAFKA-1731) add config/jmx changes in 0.8.2 doc

[ https://issues.apache.org/jira/browse/KAFKA-1731?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14260487#comment-14260487 ] Neha Narkhede commented on KAFKA-1731: -- [~junrao] Is this ready to be checked in?

[jira] [Updated] (KAFKA-1790) Remote controlled shutdown was removed

[ https://issues.apache.org/jira/browse/KAFKA-1790?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-1790: - Fix Version/s: (was: 0.8.2) 0.8.3 Remote controlled shutdown was removed

[jira] [Updated] (KAFKA-1757) Can not delete Topic index on Windows

[ https://issues.apache.org/jira/browse/KAFKA-1757?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-1757: - Fix Version/s: (was: 0.8.2) 0.8.3 I'm leaning towards pushing this out of

[jira] [Updated] (KAFKA-1782) Junit3 Misusage

[ https://issues.apache.org/jira/browse/KAFKA-1782?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-1782: - Fix Version/s: (was: 0.8.2) 0.8.3 Junit3 Misusage ---

[jira] [Commented] (KAFKA-1792) change behavior of --generate to produce assignment config with fair replica distribution and minimal number of reassignments

[ https://issues.apache.org/jira/browse/KAFKA-1792?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14260494#comment-14260494 ] Neha Narkhede commented on KAFKA-1792: -- [~Dmitry Pekar] Since this is a user facing

[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-tabpanelfocusedCommentId=14260500#comment-14260500 ] Ashish Kumar Singh commented on KAFKA-1664: --- [~nehanarkhede] still waiting for

[jira] [Commented] (KAFKA-313) Add JSON/CSV output and looping options to ConsumerOffsetChecker

[ https://issues.apache.org/jira/browse/KAFKA-313?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14260501#comment-14260501 ] Ashish Kumar Singh commented on KAFKA-313: -- [~jjkoshy], still waiting for your

[jira] [Commented] (KAFKA-1784) Implement a ConsumerOffsetClient library

[ https://issues.apache.org/jira/browse/KAFKA-1784?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14260506#comment-14260506 ] Mayuresh Gharat commented on KAFKA-1784: I suppose we don't require this ticket.

[jira] [Commented] (KAFKA-1642) [Java New Producer Kafka Trunk] CPU Usage Spike to 100% when network connection is lost

[ https://issues.apache.org/jira/browse/KAFKA-1642?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14260508#comment-14260508 ] Neha Narkhede commented on KAFKA-1642: -- Thanks for following through on this,

Review Request 29467: Patch for KAFKA-1660

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/29467/ --- Review request for kafka. Bugs: KAFKA-1660

[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-tabpanelfocusedCommentId=14260510#comment-14260510 ] Parth Brahmbhatt commented on KAFKA-1660: - Created reviewboard

[jira] [Updated] (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:all-tabpanel ] Parth Brahmbhatt updated KAFKA-1660: Attachment: KAFKA-1660.patch Ability to call close() with a timeout on the Java Kafka

Re: Review Request 29467: Patch for KAFKA-1660

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/29467/ --- (Updated Dec. 29, 2014, 10:52 p.m.) Review request for kafka. Changes

[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-tabpanelfocusedCommentId=14260511#comment-14260511 ] Parth Brahmbhatt commented on KAFKA-1660: - https://reviews.apache.org/r/29467/

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

[ https://issues.apache.org/jira/browse/KAFKA-1282?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14260516#comment-14260516 ] Nicolae Marasoiu commented on KAFKA-1282: - I will do unit tests tommorow / day

[jira] [Commented] (KAFKA-1805) Kafka ProducerRecord should implement equals

[ https://issues.apache.org/jira/browse/KAFKA-1805?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14260520#comment-14260520 ] Parth Brahmbhatt commented on KAFKA-1805: - Created reviewboard

Review Request 29468: Patch for KAFKA-1805

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/29468/ --- Review request for kafka. Bugs: KAFKA-1805

[jira] [Updated] (KAFKA-1805) Kafka ProducerRecord should implement equals

[ https://issues.apache.org/jira/browse/KAFKA-1805?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Parth Brahmbhatt updated KAFKA-1805: Attachment: KAFKA-1805.patch Kafka ProducerRecord should implement equals

[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-tabpanelfocusedCommentId=14260537#comment-14260537 ] Neha Narkhede commented on KAFKA-1781: -- [~charmalloc]. Just checking to see if you

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

[ https://issues.apache.org/jira/browse/KAFKA-1779?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-1779: - Fix Version/s: (was: 0.8.2) FetchRequest.maxWait has no effect

[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 ] Neha Narkhede updated KAFKA-1724: - Reviewer: Jun Rao Errors after reboot in single node setup

[jira] [Commented] (KAFKA-1825) leadership election state is stale and never recovers without all brokers restarting

[ https://issues.apache.org/jira/browse/KAFKA-1825?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14260572#comment-14260572 ] Neha Narkhede commented on KAFKA-1825: -- [~charmalloc] You can look at the state

[jira] [Resolved] (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 resolved KAFKA-1781. -- Resolution: Duplicate [~nehanarkhede] done Readme should specify that Gradle 2.0 is required for

[jira] [Updated] (KAFKA-1624) bump up default scala version to 2.10.4 to compile with java 8

[ https://issues.apache.org/jira/browse/KAFKA-1624?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Joe Stein updated KAFKA-1624: - Summary: bump up default scala version to 2.10.4 to compile with java 8 (was: building on JDK 8 fails)

[jira] [Commented] (KAFKA-1624) bump up default scala version to 2.10.4 to compile with java 8

[ https://issues.apache.org/jira/browse/KAFKA-1624?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14260579#comment-14260579 ] Joe Stein commented on KAFKA-1624: -- committed to 0.8.2 branch, just noticed the commit

[jira] [Commented] (KAFKA-42) Support rebalancing the partitions with replication

[ https://issues.apache.org/jira/browse/KAFKA-42?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14260596#comment-14260596 ] Parth Brahmbhatt commented on KAFKA-42: --- Updated reviewboard

[jira] [Updated] (KAFKA-42) Support rebalancing the partitions with replication

[ https://issues.apache.org/jira/browse/KAFKA-42?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Parth Brahmbhatt updated KAFKA-42: -- Attachment: KAFKA-42_2014-12-29_16:36:41.patch Support rebalancing the partitions with

[jira] [Commented] (KAFKA-1805) Kafka ProducerRecord should implement equals

[ https://issues.apache.org/jira/browse/KAFKA-1805?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14260597#comment-14260597 ] Parth Brahmbhatt commented on KAFKA-1805: - Updated reviewboard

Re: Review Request 29468: Patch for KAFKA-1805

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/29468/ --- (Updated Dec. 30, 2014, 12:37 a.m.) Review request for kafka. Bugs:

[jira] [Updated] (KAFKA-1805) Kafka ProducerRecord should implement equals

[ https://issues.apache.org/jira/browse/KAFKA-1805?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Parth Brahmbhatt updated KAFKA-1805: Attachment: KAFKA-1805_2014-12-29_16:37:11.patch Kafka ProducerRecord should implement

Re: Review Request 29029: Patch for KAFKA-1512

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/29029/#review66324 --- Ship it! Ship It! - Jay Kreps On Dec. 24, 2014, 2:47 a.m., Jeff

[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 ] Joe Stein updated KAFKA-1650: - Fix Version/s: 0.8.3 Mirror Maker could lose data on unclean shutdown.

[jira] [Updated] (KAFKA-1825) leadership election state is stale and never recovers without all brokers restarting

[ https://issues.apache.org/jira/browse/KAFKA-1825?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Joe Stein updated KAFKA-1825: - Fix Version/s: (was: 0.8.2) 0.8.3 leadership election state is stale and never

[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-tabpanelfocusedCommentId=14260751#comment-14260751 ] Guozhang Wang commented on KAFKA-1779: -- [~nehanarkhede] Is this really an issue? I

[jira] [Commented] (KAFKA-1830) Closing socket connection to /10.118.192.104. (kafka.network.Processor)

[ https://issues.apache.org/jira/browse/KAFKA-1830?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14260761#comment-14260761 ] Guozhang Wang commented on KAFKA-1830: -- Tapas, this log entry is expected as clients

[jira] [Resolved] (KAFKA-1830) Closing socket connection to /10.118.192.104. (kafka.network.Processor)

[ https://issues.apache.org/jira/browse/KAFKA-1830?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-1830. -- Resolution: Not a Problem Assignee: (was: Jay Kreps) Closing socket connection to

Review Request 29476: Patch for KAFKA-1834

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/29476/ --- Review request for kafka. Bugs: KAFKA-1834

[jira] [Updated] (KAFKA-1834) No Response when handle LeaderAndIsrRequest some case

[ https://issues.apache.org/jira/browse/KAFKA-1834?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xiajun updated KAFKA-1834: -- Attachment: KAFKA-1834.patch No Response when handle LeaderAndIsrRequest some case

[jira] [Commented] (KAFKA-1834) No Response when handle LeaderAndIsrRequest some case

[ https://issues.apache.org/jira/browse/KAFKA-1834?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14260839#comment-14260839 ] xiajun commented on KAFKA-1834: --- Created reviewboard

Re: Review Request 29476: Patch for KAFKA-1834

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/29476/ --- (Updated 十二月 30, 2014, 6:01 a.m.) Review request for kafka. Bugs: KAFKA-1834

Review Request 29475: Patch for KAFKA-1833

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/29475/ --- Review request for kafka. Summary (updated) - Patch for

[jira] [Commented] (KAFKA-1833) OfflinePartitionLeaderSelector may return null leader when ISR and Assgined Broker have no common

[ https://issues.apache.org/jira/browse/KAFKA-1833?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14260844#comment-14260844 ] xiajun commented on KAFKA-1833: --- Created reviewboard

[jira] [Updated] (KAFKA-1833) OfflinePartitionLeaderSelector may return null leader when ISR and Assgined Broker have no common

[ https://issues.apache.org/jira/browse/KAFKA-1833?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xiajun updated KAFKA-1833: -- Attachment: KAFKA-1883.patch OfflinePartitionLeaderSelector may return null leader when ISR and Assgined