[jira] [Commented] (KAFKA-1539) Due to OS caching Kafka might loose offset files which causes full reset of data

[ https://issues.apache.org/jira/browse/KAFKA-1539?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14062973#comment-14062973 ] Jun Rao commented on KAFKA-1539: If flush is not guaranteed, will keeping two versions of

Re: Review Request 23208: Patch for KAFKA-1512

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/23208/#review47841 --- Ship it! Ship It! - Jun Rao On July 14, 2014, 8:28 p.m., Jay Kre

[jira] [Created] (KAFKA-1540) Gradle error "Could not create task of type 'ScalaDoc'"

Joel Koshy created KAFKA-1540: - Summary: Gradle error "Could not create task of type 'ScalaDoc'" Key: KAFKA-1540 URL: https://issues.apache.org/jira/browse/KAFKA-1540 Project: Kafka Issue Type: B

Jenkins build is back to normal : Kafka-trunk #222

See

[jira] [Resolved] (KAFKA-1529) transient unit test failure in testAutoCreateAfterDeleteTopic

[ https://issues.apache.org/jira/browse/KAFKA-1529?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao resolved KAFKA-1529. Resolution: Fixed Fix Version/s: 0.8.2 Thanks for the reviews. Committed to trunk. > transient unit

[jira] [Updated] (KAFKA-1414) Speedup broker startup after hard reset

[ https://issues.apache.org/jira/browse/KAFKA-1414?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anton Karamanov updated KAFKA-1414: --- Attachment: 0001-KAFKA-1414-Speedup-broker-startup-after-hard-reset-a.patch Sure. [^0001-KAFK

[jira] [Commented] (KAFKA-1414) Speedup broker startup after hard reset

[ https://issues.apache.org/jira/browse/KAFKA-1414?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14062695#comment-14062695 ] Jun Rao commented on KAFKA-1414: Anton, Thanks for the patch. Could you add the patch as

[jira] [Commented] (KAFKA-1414) Speedup broker startup after hard reset

[ https://issues.apache.org/jira/browse/KAFKA-1414?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14062686#comment-14062686 ] Anton Karamanov commented on KAFKA-1414: Indeed, patch was malformed. I've fixed

[jira] [Commented] (KAFKA-1414) Speedup broker startup after hard reset

[ https://issues.apache.org/jira/browse/KAFKA-1414?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14062680#comment-14062680 ] ASF GitHub Bot commented on KAFKA-1414: --- GitHub user ataraxer opened a pull request:

[GitHub] kafka pull request: KAFKA-1414: Speedup broker startup after hard ...

GitHub user ataraxer opened a pull request: https://github.com/apache/kafka/pull/26 KAFKA-1414: Speedup broker startup after hard reset and shutdown This patch increases speed of both hard reset and shutdown by introducing `log.recovery.threads` and `log.shutdown.threads` properties

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

[ https://issues.apache.org/jira/browse/KAFKA-1533?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-1533: - Attachment: KAFKA-1533.patch > transient unit test failure in ProducerFailureHandlingTest > -

[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=14062614#comment-14062614 ] Guozhang Wang commented on KAFKA-1533: -- Created reviewboard https://reviews.apache.or

Review Request 23521: Fix KAFKA-1533

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

Re: Review Request 23474: Patch for KAFKA-1483

> On July 15, 2014, 5:51 p.m., Guozhang Wang wrote: > > core/src/main/scala/kafka/server/ReplicaManager.scala, line 484 > > > > > > I am wondering if this function will introduce more lock contention on > > leaderIsrU

Re: Review Request 23474: Patch for KAFKA-1483

> On July 15, 2014, 5:51 p.m., Guozhang Wang wrote: > > core/src/main/scala/kafka/server/ReplicaManager.scala, line 484 > > > > > > I am wondering if this function will introduce more lock contention on > > leaderIsrU

[jira] [Updated] (KAFKA-1462) Add new request and response formats for the new consumer and coordinator communication

[ https://issues.apache.org/jira/browse/KAFKA-1462?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-1462: --- Attachment: KAFKA-1462.patch > Add new request and response formats for the new consumer and coordinator > c

Re: Review Request 23516: Patch for KAFKA-1462

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/23516/ --- (Updated July 15, 2014, 6:36 p.m.) Review request for kafka. Bugs: KAFKA-1462

[jira] [Commented] (KAFKA-1462) Add new request and response formats for the new consumer and coordinator communication

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

Review Request 23516: Patch for KAFKA-1462

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

Re: Review Request 23474: Patch for KAFKA-1483

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/23474/#review47785 --- core/src/main/scala/kafka/server/ReplicaManager.scala

[jira] [Updated] (KAFKA-1534) transient unit test failure in testBasicPreferredReplicaElection

[ https://issues.apache.org/jira/browse/KAFKA-1534?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-1534: - Labels: newbie (was: ) > transient unit test failure in testBasicPreferredReplicaElection >

[jira] [Commented] (KAFKA-1019) kafka-preferred-replica-election.sh will fail without clear error message if /brokers/topics/[topic]/partitions does not exist

[ https://issues.apache.org/jira/browse/KAFKA-1019?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14062323#comment-14062323 ] Neha Narkhede commented on KAFKA-1019: -- [~draiwn] were you able to confirm the issue

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

[ https://issues.apache.org/jira/browse/KAFKA-1517?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-1517: - Labels: newbie (was: ) > Messages is a required argument to Producer Performance Test >

[jira] [Commented] (KAFKA-1529) transient unit test failure in testAutoCreateAfterDeleteTopic

[ https://issues.apache.org/jira/browse/KAFKA-1529?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14062274#comment-14062274 ] Neha Narkhede commented on KAFKA-1529: -- [~junrao], would you like to check this in?

Re: Review Request 23294: Patch for KAFKA-1529

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/23294/#review47778 --- Ship it! Ship It! - Neha Narkhede On July 6, 2014, 6:40 p.m., Ju

[jira] [Resolved] (KAFKA-1521) Producer Graceful Shutdown issue in Container (Kafka version 0.8.x.x)

[ https://issues.apache.org/jira/browse/KAFKA-1521?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede resolved KAFKA-1521. -- Resolution: Won't Fix Closing as per [~junrao]'s comment. [~Bmis13] Please reopen if you have

[jira] [Updated] (KAFKA-1519) Console consumer: expose configuration option to enable/disable writing the line separator

[ https://issues.apache.org/jira/browse/KAFKA-1519?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-1519: - Labels: newbie (was: ) > Console consumer: expose configuration option to enable/disable writing

[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=14062214#comment-14062214 ] Jay Kreps commented on KAFKA-1535: -- Yeah we do all development on trunk and just cut bran

[jira] [Updated] (KAFKA-1325) Fix inconsistent per topic log configs

[ https://issues.apache.org/jira/browse/KAFKA-1325?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-1325: - Labels: newbie usability (was: usability) > Fix inconsistent per topic log configs > ---

Query regarding Kafka partitions and Consumer rebalancing

Hi, Currently we trying to configure Kafka in our system for pulling messages from Queues. We have multiple consumers( we might want to add consumers if load on one consumer increases) which need to receive and process messages from a Kafka queue. Based on my understanding, under a single consume

[jira] [Commented] (KAFKA-1414) Speedup broker startup after hard reset

[ https://issues.apache.org/jira/browse/KAFKA-1414?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14061957#comment-14061957 ] Alexey Ozeritskiy commented on KAFKA-1414: -- Anton, you forget to use new config o