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

2015-04-05 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1809?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14440933#comment-14440933 ] Jun Rao commented on KAFKA-1809: [~gwenshap], thanks a lot for your patience and effort. +

[jira] [Updated] (KAFKA-1926) Replace kafka.utils.Utils with o.a.k.common.utils.Utils

2015-04-05 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1926?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-1926: --- Resolution: Fixed Fix Version/s: 0.8.3 Status: Resolved (was: Patch Available) Thanks for r

[jira] [Commented] (KAFKA-1926) Replace kafka.utils.Utils with o.a.k.common.utils.Utils

2015-04-06 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1926?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14481262#comment-14481262 ] Jun Rao commented on KAFKA-1926: Typically, IDE (e.g., intellij) shows unused imports. >

[jira] [Commented] (KAFKA-2082) Kafka Replication ends up in a bad state

2015-04-06 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2082?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14481843#comment-14481843 ] Jun Rao commented on KAFKA-2082: After step 2), which broker is the new controller? The ne

[jira] [Commented] (KAFKA-2078) Getting Selector [WARN] Error in I/O with host java.io.EOFException

2015-04-06 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2078?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14481861#comment-14481861 ] Jun Rao commented on KAFKA-2078: What kind of network do you have? Do you have any load ba

[jira] [Updated] (KAFKA-2043) CompressionType is passed in each RecordAccumulator append

2015-04-06 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2043?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-2043: --- Resolution: Fixed Fix Version/s: 0.8.3 Status: Resolved (was: Patch Available) Thanks for t

[jira] [Commented] (KAFKA-2096) Enable keepalive socket option for broker to prevent socket leak

2015-04-06 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2096?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14481890#comment-14481890 ] Jun Rao commented on KAFKA-2096: [~allenxwang], that seems to be a good fix. Do you want t

[jira] [Resolved] (KAFKA-2086) testRoundRobinPartitionAssignor transient failure

2015-04-06 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2086?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao resolved KAFKA-2086. Resolution: Duplicate Yes. Closing this one. > testRoundRobinPartitionAssignor transient failure >

[jira] [Closed] (KAFKA-2086) testRoundRobinPartitionAssignor transient failure

2015-04-06 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2086?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao closed KAFKA-2086. -- > testRoundRobinPartitionAssignor transient failure > - > >

[jira] [Updated] (KAFKA-2099) BrokerEndPoint file, methods and object names should match

2015-04-06 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2099?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-2099: --- Resolution: Fixed Fix Version/s: 0.8.3 Status: Resolved (was: Patch Available) Thanks for t

[jira] [Updated] (KAFKA-2033) Small typo in documentation

2015-04-07 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2033?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-2033: --- Resolution: Fixed Fix Version/s: 0.8.3 Status: Resolved (was: Patch Available) Thanks for t

[jira] [Commented] (KAFKA-1993) Enable topic deletion as default

2015-04-07 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1993?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14484126#comment-14484126 ] Jun Rao commented on KAFKA-1993: Perhaps we should wait until the security feature is done

[jira] [Updated] (KAFKA-1993) Enable topic deletion as default

2015-04-07 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1993?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-1993: --- Status: Open (was: Patch Available) > Enable topic deletion as default > > >

[jira] [Updated] (KAFKA-1992) Following KAFKA-1697, checkEnoughReplicasReachOffset doesn't need to get requiredAcks

2015-04-07 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1992?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-1992: --- Resolution: Fixed Fix Version/s: 0.8.3 Status: Resolved (was: Patch Available) Thanks for t

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

2015-04-07 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1982?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-1982: --- Status: In Progress (was: Patch Available) Sorry for the late review. Left a few more comments on the RB. >

[jira] [Updated] (KAFKA-1954) Speed Up The Unit Tests

2015-04-07 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1954?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-1954: --- Status: In Progress (was: Patch Available) Thanks for the patch. Left a few review comments on the RB. > Spe

[jira] [Updated] (KAFKA-1973) Remove the accidentally created LogCleanerManager.scala.orig

2015-04-07 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1973?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-1973: --- Resolution: Fixed Fix Version/s: 0.8.3 Status: Resolved (was: Patch Available) Thanks for t

[jira] [Updated] (KAFKA-1953) Disambiguate metrics from different purgatories

2015-04-07 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1953?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-1953: --- Resolution: Fixed Fix Version/s: 0.8.3 Status: Resolved (was: Patch Available) Resolved thi

[jira] [Updated] (KAFKA-1907) ZkClient can block controlled shutdown indefinitely

2015-04-07 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1907?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-1907: --- Status: In Progress (was: Patch Available) > ZkClient can block controlled shutdown indefinitely > --

[jira] [Updated] (KAFKA-1906) Default the Kafka log directory to a relative path within the Kafka installation directory

2015-04-07 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1906?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-1906: --- Status: In Progress (was: Patch Available) > Default the Kafka log directory to a relative path within the Ka

[jira] [Updated] (KAFKA-1888) Add a "rolling upgrade" system test

2015-04-07 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1888?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-1888: --- Status: In Progress (was: Patch Available) > Add a "rolling upgrade" system test > --

[jira] [Updated] (KAFKA-1887) controller error message on shutting the last broker

2015-04-07 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1887?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-1887: --- Status: In Progress (was: Patch Available) > controller error message on shutting the last broker > -

[jira] [Updated] (KAFKA-1882) Create extendable channel interface and default implementations

2015-04-07 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1882?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-1882: --- Status: In Progress (was: Patch Available) > Create extendable channel interface and default implementations

[jira] [Updated] (KAFKA-1802) Add a new type of request for the discovery of the controller

2015-04-07 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1802?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-1802: --- Status: In Progress (was: Patch Available) > Add a new type of request for the discovery of the controller >

[jira] [Updated] (KAFKA-1775) Re-factor TopicCommand into thew handerAdminMessage call

2015-04-07 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1775?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-1775: --- Status: In Progress (was: Patch Available) > Re-factor TopicCommand into thew handerAdminMessage call >

[jira] [Updated] (KAFKA-1774) REPL and Shell Client for Admin Message RQ/RP

2015-04-07 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1774?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-1774: --- Status: In Progress (was: Patch Available) > REPL and Shell Client for Admin Message RQ/RP >

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

2015-04-07 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1772?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-1772: --- Status: In Progress (was: Patch Available) > Add an Admin message type for request response > ---

[jira] [Updated] (KAFKA-1753) add --decommission-broker option

2015-04-07 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1753?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-1753: --- Status: In Progress (was: Patch Available) > add --decommission-broker option > -

[jira] [Updated] (KAFKA-1737) Document required ZkSerializer for ZkClient used with AdminUtils

2015-04-07 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1737?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-1737: --- Status: In Progress (was: Patch Available) > Document required ZkSerializer for ZkClient used with AdminUtils

[jira] [Updated] (KAFKA-1675) bootstrapping tidy-up

2015-04-07 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1675?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-1675: --- Status: In Progress (was: Patch Available) > bootstrapping tidy-up > - > >

[jira] [Updated] (KAFKA-1669) Default rebalance retries and backoff should be higher

2015-04-07 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1669?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-1669: --- Resolution: Won't Fix Status: Resolved (was: Patch Available) Resolving this for now. Please reopen i

[jira] [Updated] (KAFKA-1517) Messages is a required argument to Producer Performance Test

2015-04-07 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1517?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-1517: --- Resolution: Fixed Fix Version/s: 0.8.3 Assignee: Daniel Compton Status: Resolved (w

[jira] [Updated] (KAFKA-1277) Keep the summery/description when updating the RB with kafka-patch-review

2015-04-07 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1277?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-1277: --- Status: In Progress (was: Patch Available) > Keep the summery/description when updating the RB with kafka-pat

[jira] [Updated] (KAFKA-1215) Rack-Aware replica assignment option

2015-04-07 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1215?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-1215: --- Status: In Progress (was: Patch Available) > Rack-Aware replica assignment option > -

[jira] [Updated] (KAFKA-902) Randomize backoff on the clients for metadata requests

2015-04-07 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-902?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-902: -- Status: In Progress (was: Patch Available) > Randomize backoff on the clients for metadata requests > --

[jira] [Updated] (KAFKA-2104) testDuplicateListeners() has a typo

2015-04-08 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2104?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-2104: --- Resolution: Fixed Fix Version/s: 0.8.3 Status: Resolved (was: Patch Available) Thanks for t

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

2015-04-10 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2068?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14490534#comment-14490534 ] Jun Rao commented on KAFKA-2068: [~guozhang], do you plan to take this on? Thanks, > Repl

[jira] [Updated] (KAFKA-1927) Replace requests in kafka.api with requests in org.apache.kafka.common.requests

2015-04-10 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1927?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-1927: --- Status: In Progress (was: Patch Available) Actual patch is now distributed in sub jiras. > Replace requests

[jira] [Commented] (KAFKA-1669) Default rebalance retries and backoff should be higher

2015-04-08 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1669?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14486210#comment-14486210 ] Jun Rao commented on KAFKA-1669: [~clarkhaskins], wouldn't it be better to change the conf

[jira] [Commented] (KAFKA-2096) Enable keepalive socket option for broker to prevent socket leak

2015-04-08 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2096?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14486297#comment-14486297 ] Jun Rao commented on KAFKA-2096: We probably don't need to make this configurable. The def

[jira] [Updated] (KAFKA-2087) TopicConfigManager javadoc references incorrect paths

2015-04-08 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2087?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-2087: --- Priority: Trivial (was: Minor) > TopicConfigManager javadoc references incorrect paths >

[jira] [Commented] (KAFKA-1669) Default rebalance retries and backoff should be higher

2015-04-08 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1669?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14486238#comment-14486238 ] Jun Rao commented on KAFKA-1669: If you start more than 1 consumer concurrently, there cou

[jira] [Commented] (KAFKA-1367) Broker topic metadata not kept in sync with ZooKeeper

2015-04-09 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1367?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14488218#comment-14488218 ] Jun Rao commented on KAFKA-1367: [~Skandragon], for the operational issue that you pointed

[jira] [Commented] (KAFKA-2078) Getting Selector [WARN] Error in I/O with host java.io.EOFException

2015-04-08 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2078?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14486433#comment-14486433 ] Jun Rao commented on KAFKA-2078: That's a good point. Do you see any OOME in either the br

[jira] [Updated] (KAFKA-1989) New purgatory design

2015-04-08 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1989?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-1989: --- Resolution: Fixed Fix Version/s: 0.8.3 Status: Resolved (was: Patch Available) Thanks for t

[jira] [Commented] (KAFKA-2077) Add ability to specify a TopicPicker class for KafkaLog4jApender

2015-04-08 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2077?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14486562#comment-14486562 ] Jun Rao commented on KAFKA-2077: Thanks for the patch. The customizable key class seems us

[jira] [Commented] (KAFKA-2077) Add ability to specify a TopicPicker class for KafkaLog4jApender

2015-04-08 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2077?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14486575#comment-14486575 ] Jun Rao commented on KAFKA-2077: Also, does this patch cover KAFKA-2041 as well? > Add ab

[jira] [Commented] (KAFKA-1993) Enable topic deletion as default

2015-04-08 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1993?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14486073#comment-14486073 ] Jun Rao commented on KAFKA-1993: [~onurkaraman], yes, we can remove the config for contro

[jira] [Updated] (KAFKA-1788) producer record can stay in RecordAccumulator forever if leader is no available

2015-04-09 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1788?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-1788: --- Assignee: Parth Brahmbhatt (was: Jun Rao) > producer record can stay in RecordAccumulator forever if leader i

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

2015-04-08 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1809?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-1809: --- Resolution: Fixed Fix Version/s: 0.8.3 Status: Resolved (was: Patch Available) Resolving th

[jira] [Commented] (KAFKA-1554) Corrupt index found on clean startup

2015-04-08 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1554?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14486465#comment-14486465 ] Jun Rao commented on KAFKA-1554: Yes, I am not sure if auto fixing the index is better. Pe

[jira] [Resolved] (KAFKA-2110) Doc: Clarify that max number of consumer instances is per consumer group

2015-04-08 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2110?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao resolved KAFKA-2110. Resolution: Fixed Fix Version/s: 0.8.3 Assignee: Peter Vandenabeele Thanks for reporting thi

[jira] [Updated] (KAFKA-2109) Support retries in KafkaLog4jAppender

2015-04-08 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2109?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-2109: --- Resolution: Fixed Fix Version/s: 0.8.3 Status: Resolved (was: Patch Available) Thanks for t

[jira] [Updated] (KAFKA-2077) Add ability to specify a TopicPicker class for KafkaLog4jApender

2015-04-09 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2077?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-2077: --- Reviewer: (was: Gwen Shapira) > Add ability to specify a TopicPicker class for KafkaLog4jApender > -

[jira] [Updated] (KAFKA-2096) Enable keepalive socket option for broker to prevent socket leak

2015-04-08 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2096?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-2096: --- Resolution: Fixed Fix Version/s: 0.8.3 Assignee: Allen Wang (was: Jun Rao) Status:

[jira] [Updated] (KAFKA-2036) Consumer and broker have different networks

2015-04-09 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2036?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-2036: --- Status: Patch Available (was: Open) > Consumer and broker have different networks > -

[jira] [Resolved] (KAFKA-2090) Remove duplicate check to metadataFetchInProgress

2015-04-08 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2090?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao resolved KAFKA-2090. Resolution: Fixed Fix Version/s: 0.8.3 Assignee: Tim Brooks Thanks for the patch. +1 and com

[jira] [Updated] (KAFKA-1933) Fine-grained locking in log append

2015-04-09 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1933?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-1933: --- Status: Patch Available (was: Open) > Fine-grained locking in log append > --

[jira] [Updated] (KAFKA-1933) Fine-grained locking in log append

2015-04-09 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1933?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-1933: --- Assignee: Maxim Ivanov (was: Jay Kreps) > Fine-grained locking in log append > --

[jira] [Commented] (KAFKA-1123) Broker IPv6 addresses parsed incorrectly

2015-04-08 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1123?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14486093#comment-14486093 ] Jun Rao commented on KAFKA-1123: The new producer needs to use bootstrap.servers, instead

[jira] [Updated] (KAFKA-2087) TopicConfigManager javadoc references incorrect paths

2015-04-08 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2087?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-2087: --- Status: Patch Available (was: Open) > TopicConfigManager javadoc references incorrect paths > ---

[jira] [Commented] (KAFKA-2091) Expose a Partitioner interface in the new producer

2015-04-08 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2091?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14486492#comment-14486492 ] Jun Rao commented on KAFKA-2091: This introduces a new interface in the producer client. S

[jira] [Updated] (KAFKA-2112) make overflowWheel volatile

2015-04-09 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2112?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-2112: --- Resolution: Fixed Fix Version/s: 0.8.3 Status: Resolved (was: Patch Available) Thanks for t

[jira] [Commented] (KAFKA-1669) Default rebalance retries and backoff should be higher

2015-04-08 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1669?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14486265#comment-14486265 ] Jun Rao commented on KAFKA-1669: It's possible. However, since we are developing the new c

[jira] [Updated] (KAFKA-2077) Add ability to specify a TopicPicker class for KafkaLog4jApender

2015-04-09 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2077?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-2077: --- Reviewer: Gwen Shapira > Add ability to specify a TopicPicker class for KafkaLog4jApender > --

[jira] [Updated] (KAFKA-2029) Improving controlled shutdown for rolling updates

2015-04-08 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2029?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-2029: --- Status: Patch Available (was: Open) > Improving controlled shutdown for rolling updates > ---

[jira] [Commented] (KAFKA-2082) Kafka Replication ends up in a bad state

2015-04-08 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2082?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14486536#comment-14486536 ] Jun Rao commented on KAFKA-2082: My understanding is that if a broker is isolated from ZK,

[jira] [Created] (KAFKA-2117) OffsetManager uses incorrect field for metadata

2015-04-12 Thread Jun Rao (JIRA)
Jun Rao created KAFKA-2117: -- Summary: OffsetManager uses incorrect field for metadata Key: KAFKA-2117 URL: https://issues.apache.org/jira/browse/KAFKA-2117 Project: Kafka Issue Type: Bug C

[jira] [Commented] (KAFKA-2117) OffsetManager uses incorrect field for metadata

2015-04-12 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2117?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14491865#comment-14491865 ] Jun Rao commented on KAFKA-2117: The issue seems to be that we should be using the metadat

[jira] [Updated] (KAFKA-2115) Error updating metrics in RequestChannel

2015-04-12 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2115?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-2115: --- Status: In Progress (was: Patch Available) > Error updating metrics in RequestChannel > -

[jira] [Updated] (KAFKA-2115) Error updating metrics in RequestChannel

2015-04-13 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2115?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-2115: --- Resolution: Fixed Fix Version/s: 0.8.3 Status: Resolved (was: Patch Available) Thanks for t

[jira] [Updated] (KAFKA-2056) PartitionAssignorTest.testRangePartitionAssignor transient failure

2015-04-13 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2056?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-2056: --- Assignee: Fangmin Lv Status: Patch Available (was: Open) > PartitionAssignorTest.testRangePartitionAssi

[jira] [Updated] (KAFKA-2102) Remove unnecessary synchronization when managing metadata

2015-04-13 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2102?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-2102: --- Status: In Progress (was: Patch Available) > Remove unnecessary synchronization when managing metadata >

[jira] [Updated] (KAFKA-2113) TestPurgatoryPerformance does not compile using IBM JDK

2015-04-16 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2113?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-2113: --- Resolution: Fixed Fix Version/s: 0.8.3 Status: Resolved (was: Patch Available) Thanks for t

[jira] [Commented] (KAFKA-2088) kafka-console-consumer.sh should not create zookeeper path when no brokers found and chroot was set in zookeeper.connect

2015-04-17 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2088?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14500330#comment-14500330 ] Jun Rao commented on KAFKA-2088: [~ransom], thanks for the patch. It may be reasonable to

[jira] [Updated] (KAFKA-1990) Add unlimited time-based log retention

2015-04-17 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1990?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-1990: --- Status: In Progress (was: Patch Available) > Add unlimited time-based log retention > ---

[jira] [Updated] (KAFKA-2118) Cleaner cannot clean after shutdown during replaceSegments

2015-04-17 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2118?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-2118: --- Status: In Progress (was: Patch Available) > Cleaner cannot clean after shutdown during replaceSegments > ---

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

2015-04-17 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1982?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-1982: --- Status: In Progress (was: Patch Available) > change kafka.examples.Producer to use the new java producer > --

[jira] [Updated] (KAFKA-1928) Move kafka.network over to using the network classes in org.apache.kafka.common.network

2015-04-17 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1928?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-1928: --- Status: In Progress (was: Patch Available) > Move kafka.network over to using the network classes in > org.a

[jira] [Updated] (KAFKA-1690) new java producer needs ssl support as a client

2015-04-17 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1690?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-1690: --- Status: In Progress (was: Patch Available) [~sriharsha], your original patch in KAFKA-1684 only added the SSL

[jira] [Updated] (KAFKA-2119) ConsumerRecord key() and value() methods should not have throws Exception

2015-04-17 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2119?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-2119: --- Resolution: Fixed Status: Resolved (was: Patch Available) Thanks for the patch. +1 and committed to t

[jira] [Updated] (KAFKA-2088) kafka-console-consumer.sh should not create zookeeper path when no brokers found and chroot was set in zookeeper.connect

2015-04-18 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2088?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-2088: --- Resolution: Fixed Fix Version/s: 0.8.3 Status: Resolved (was: Patch Available) Thanks for t

[jira] [Updated] (KAFKA-2036) Consumer and broker have different networks

2015-04-18 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2036?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-2036: --- Status: In Progress (was: Patch Available) Thanks for the patch. The new consumer/producer client will be usi

[jira] [Updated] (KAFKA-1994) Evaluate performance effect of chroot check on Topic creation

2015-04-18 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1994?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-1994: --- Resolution: Fixed Fix Version/s: 0.8.3 Status: Resolved (was: Patch Available) Thanks for t

[jira] [Updated] (KAFKA-1554) Corrupt index found on clean startup

2015-04-18 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1554?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-1554: --- Status: In Progress (was: Patch Available) > Corrupt index found on clean startup > -

[jira] [Updated] (KAFKA-1420) Replace AdminUtils.createOrUpdateTopicPartitionAssignmentPathInZK with TestUtils.createTopic in unit tests

2015-04-18 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1420?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-1420: --- Status: In Progress (was: Patch Available) > Replace AdminUtils.createOrUpdateTopicPartitionAssignmentPathInZ

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

2015-04-19 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1982?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-1982: --- Resolution: Fixed Fix Version/s: 0.8.3 Status: Resolved (was: Patch Available) Thanks for t

[jira] [Updated] (KAFKA-2131) Update new producer javadocs with correct documentation links

2015-04-19 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2131?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-2131: --- Resolution: Fixed Fix Version/s: 0.8.3 Status: Resolved (was: Patch Available) Thanks for t

[jira] [Updated] (KAFKA-1929) Convert core kafka module to use the errors in org.apache.kafka.common.errors

2015-04-19 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1929?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-1929: --- Status: In Progress (was: Patch Available) > Convert core kafka module to use the errors in org.apache.kafka.

[jira] [Commented] (KAFKA-1929) Convert core kafka module to use the errors in org.apache.kafka.common.errors

2015-04-19 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1929?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14501989#comment-14501989 ] Jun Rao commented on KAFKA-1929: [~jholoman], thanks for the patch. A couple of comments.

[jira] [Commented] (KAFKA-2082) Kafka Replication ends up in a bad state

2015-04-19 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2082?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14501998#comment-14501998 ] Jun Rao commented on KAFKA-2082: In the case when a broker is isolated from ZK, the easies

[jira] [Updated] (KAFKA-2082) Kafka Replication ends up in a bad state

2015-04-19 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2082?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-2082: --- Status: In Progress (was: Patch Available) > Kafka Replication ends up in a bad state > -

[jira] [Resolved] (KAFKA-1974) NPE in SelectorTest on trunk

2015-04-19 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1974?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao resolved KAFKA-1974. Resolution: Cannot Reproduce Closing this for now. We can reopen it if it shows up again. > NPE in Selector

[jira] [Updated] (KAFKA-1990) Add unlimited time-based log retention

2015-04-19 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1990?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-1990: --- Resolution: Fixed Fix Version/s: 0.8.3 Status: Resolved (was: Patch Available) Thanks for t

[jira] [Commented] (KAFKA-2118) Cleaner cannot clean after shutdown during replaceSegments

2015-04-19 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2118?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14502317#comment-14502317 ] Jun Rao commented on KAFKA-2118: [~rsivaram], your latest patch looks good to me. [~jkrep

[jira] [Updated] (KAFKA-2118) Cleaner cannot clean after shutdown during replaceSegments

2015-04-26 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2118?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-2118: --- Resolution: Fixed Fix Version/s: 0.8.3 Status: Resolved (was: Patch Available) Thanks for t

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

2015-04-26 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1595?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14513420#comment-14513420 ] Jun Rao commented on KAFKA-1595: [~ijuma], we discussed the json library in the context of

[jira] [Commented] (KAFKA-2139) Add a separate controller messge queue with higher priority on broker side

2015-04-27 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2139?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14515079#comment-14515079 ] Jun Rao commented on KAFKA-2139: [~becket_qin], thanks for taking the initiative to redesi

[jira] [Commented] (KAFKA-2139) Add a separate controller messge queue with higher priority on broker side

2015-04-27 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2139?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14515097#comment-14515097 ] Jun Rao commented on KAFKA-2139: [~gwenshap], when starting up a broker, the broker regist

[jira] [Commented] (KAFKA-1993) Enable topic deletion as default

2015-04-27 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1993?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14515138#comment-14515138 ] Jun Rao commented on KAFKA-1993: Currently, there are still a few issues with topic deleti

<    1   2   3   4   5   6   7   8   9   10   >