[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: KAFKA-1414-rev4.patch I've updated the patch. * replaced {{log.io.parallelism}} w

Re: Review Request 23442: Updated WIP simple consumer

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/23442/#review48445 --- Ship it! Some minor comments below. clients/src/main/java/org/apa

Re: Review Request 23692: Patch for KAFKA-1550

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/23692/#review48455 --- Ship it! Ship It! - Guozhang Wang On July 22, 2014, 6:41 p.m., D

Re: Review Request 23569: Patch for KAFKA-1525

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

[jira] [Updated] (KAFKA-1523) Implement transaction manager module

[ https://issues.apache.org/jira/browse/KAFKA-1523?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-1523: Attachment: KAFKA-1523_2014-07-22_16:45:42.patch > Implement transaction manager module > -

[jira] [Commented] (KAFKA-1523) Implement transaction manager module

[ https://issues.apache.org/jira/browse/KAFKA-1523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14071130#comment-14071130 ] Dong Lin commented on KAFKA-1523: - Updated reviewboard https://reviews.apache.org/r/23568/

Re: Review Request 23568: Patch for KAFKA-1523

> On July 21, 2014, 6:56 p.m., Joel Koshy wrote: > > core/src/main/scala/kafka/server/KafkaApis.scala, line 157 > > > > > > Looking at this method in the other patch - this only gives the head - > > what about the oth

Re: Review Request 23567: Patch for KAFKA-1522

> On July 21, 2014, 5:49 p.m., Joel Koshy wrote: > > core/src/main/scala/kafka/api/TransactionRequest.scala, line 87 > > > > > > TxControlTypes would be clearer I think (also based on what I have seen > > so far in KAF

[jira] [Updated] (KAFKA-1525) DumpLogSegments should print transaction IDs

[ https://issues.apache.org/jira/browse/KAFKA-1525?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-1525: Attachment: KAFKA-1525_2014-07-22_16:48:45.patch > DumpLogSegments should print transaction IDs > -

[jira] [Issue Comment Deleted] (KAFKA-1522) Transactional messaging request/response definitions

[ https://issues.apache.org/jira/browse/KAFKA-1522?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-1522: Comment: was deleted (was: Updated reviewboard https://reviews.apache.org/r/23569/diff/ against branch ori

[jira] [Commented] (KAFKA-1525) DumpLogSegments should print transaction IDs

[ https://issues.apache.org/jira/browse/KAFKA-1525?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14071134#comment-14071134 ] Dong Lin commented on KAFKA-1525: - Updated reviewboard https://reviews.apache.org/r/23569/

Re: Review Request 23569: Patch for KAFKA-1525

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/23569/ --- (Updated July 22, 2014, 11:50 p.m.) Review request for kafka. Bugs: KAFKA-152

Re: Review Request 23568: Patch for KAFKA-1523

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/23568/ --- (Updated July 22, 2014, 11:45 p.m.) Review request for kafka. Bugs: KAFKA-152

[jira] [Updated] (KAFKA-1522) Transactional messaging request/response definitions

[ https://issues.apache.org/jira/browse/KAFKA-1522?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-1522: Attachment: KAFKA-1522_2014-07-22_16:43:18.patch > Transactional messaging request/response definitions > -

[jira] [Updated] (KAFKA-1522) Transactional messaging request/response definitions

[ https://issues.apache.org/jira/browse/KAFKA-1522?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-1522: Attachment: KAFKA-1522_2014-07-22_16:42:50.patch > Transactional messaging request/response definitions > -

[jira] [Commented] (KAFKA-1522) Transactional messaging request/response definitions

[ https://issues.apache.org/jira/browse/KAFKA-1522?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14071126#comment-14071126 ] Dong Lin commented on KAFKA-1522: - Updated reviewboard https://reviews.apache.org/r/23569/

[jira] [Commented] (KAFKA-1522) Transactional messaging request/response definitions

[ https://issues.apache.org/jira/browse/KAFKA-1522?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14071127#comment-14071127 ] Dong Lin commented on KAFKA-1522: - Updated reviewboard https://reviews.apache.org/r/23567/

Re: Review Request 23567: Patch for KAFKA-1522

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/23567/ --- (Updated July 22, 2014, 11:43 p.m.) Review request for kafka. Bugs: KAFKA-152

Re: Review Request 23569: Patch for KAFKA-1522

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

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

[ https://issues.apache.org/jira/browse/KAFKA-1420?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14071123#comment-14071123 ] Guozhang Wang commented on KAFKA-1420: -- Hello Jonathan, Thanks for the comment. You

[jira] [Commented] (KAFKA-1421) Error: Could not find or load main class kafka.perf.SimpleConsumerPerformance

[ https://issues.apache.org/jira/browse/KAFKA-1421?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14071102#comment-14071102 ] Andrew Ehrlich commented on KAFKA-1421: --- I found it in the binary download on the ho

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

[ https://issues.apache.org/jira/browse/KAFKA-1554?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14071078#comment-14071078 ] Jun Rao commented on KAFKA-1554: Is this easily reproducible? Thanks, > Corrupt index fou

[jira] [Commented] (KAFKA-1421) Error: Could not find or load main class kafka.perf.SimpleConsumerPerformance

[ https://issues.apache.org/jira/browse/KAFKA-1421?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14071071#comment-14071071 ] Jun Rao commented on KAFKA-1421: Hmm, I can't seem to find the script in trunk. Where did

Re: [GitHub] kafka pull request: Clarify log expiry configuration options (for ...

Thanks for pointing this out. Could you file a Apache jira and attach you patch there? Jun On Tue, Jul 22, 2014 at 8:40 AM, MarkRose wrote: > GitHub user MarkRose opened a pull request: > > https://github.com/apache/kafka/pull/28 > > Clarify log expiry configuration options (for trunk)

Re: Review Request 23705: Addressing Jun's comments

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/23705/#review48440 --- Looks good. Just one minor comment below. core/src/main/scala/kafk

[jira] [Commented] (KAFKA-1419) cross build for scala 2.11

[ https://issues.apache.org/jira/browse/KAFKA-1419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14071024#comment-14071024 ] Adriaan Moors commented on KAFKA-1419: -- Sorry about the sbt gymnastics! Here's how we

[jira] [Commented] (KAFKA-1421) Error: Could not find or load main class kafka.perf.SimpleConsumerPerformance

[ https://issues.apache.org/jira/browse/KAFKA-1421?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14070976#comment-14070976 ] Andrew Ehrlich commented on KAFKA-1421: --- I am seeing this behavior in 0.8.1.1 > Err

[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=14070945#comment-14070945 ] Jun Rao commented on KAFKA-1414: Anton, Just curious in your experiment, is the data comp

[jira] [Commented] (KAFKA-1549) dead brokers coming in the TopicMetadataResponse

[ https://issues.apache.org/jira/browse/KAFKA-1549?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14070933#comment-14070933 ] Jun Rao commented on KAFKA-1549: Thanks for the patch. Could we define inReadLock and inWr

Re: Review Request 23569: Patch for KAFKA-1525

> On July 22, 2014, 7:59 p.m., Joel Koshy wrote: > > Ship It! Since we recently added txControl to message header, I will also include this in the output of DumpLogSements. - Dong --- This is an automatically generated e-mail. To reply

[jira] [Resolved] (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 ] Jun Rao resolved KAFKA-1533. Resolution: Fixed Fix Version/s: 0.8.2 Assignee: Guozhang Wang Thanks for the patch. +1 and

Kafka Go Client

Hi All, I was watching the talks from the Kafka meet up at LinkedIn last month. While answering a question on producers spilling to disk, Neha mentioned that there was a Go client that had this feature. I was wondering if the client that does this is https://github.com/Shopify/sarama/issues. I'm

Re: Review Request 23569: Patch for KAFKA-1525

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/23569/#review48416 --- Ship it! Ship It! - Joel Koshy On July 16, 2014, 9:30 p.m., Dong

Re: Review Request 23648: Patch for KAFKA-1524

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/23648/#review48338 --- clients/src/main/java/org/apache/kafka/clients/NetworkClient.java <

[jira] [Updated] (KAFKA-1549) dead brokers coming in the TopicMetadataResponse

[ https://issues.apache.org/jira/browse/KAFKA-1549?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] nicu marasoiu updated KAFKA-1549: - Attachment: (was: kafka-1549__without_implicit__only_last_seen_alive_brokers_to_be_responded_

[jira] [Updated] (KAFKA-1549) dead brokers coming in the TopicMetadataResponse

[ https://issues.apache.org/jira/browse/KAFKA-1549?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] nicu marasoiu updated KAFKA-1549: - Attachment: kafka-1549__without_implicit__only_last_seen_alive_brokers_to_be_responded_part_of_th

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

[ https://issues.apache.org/jira/browse/KAFKA-1420?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14070756#comment-14070756 ] Jonathan Natkins edited comment on KAFKA-1420 at 7/22/14 7:30 PM: --

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

[ https://issues.apache.org/jira/browse/KAFKA-1420?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14070756#comment-14070756 ] Jonathan Natkins commented on KAFKA-1420: - Hi Guozhang, The particular case I'm c

[jira] [Commented] (KAFKA-1549) dead brokers coming in the TopicMetadataResponse

[ https://issues.apache.org/jira/browse/KAFKA-1549?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14070751#comment-14070751 ] nicu marasoiu commented on KAFKA-1549: -- [~jkreps] [~junrao] Hi, can you help me choos

Re: [DISCUSS] Kafka Security Specific Features

Anyone getting this issue. Is it something related to environment or it is the code. Producer works fine when run with secure=false (no security) mode. pdeshmukh$ bin/kafka-console-producer.sh --broker-list localhost:9092:true --topic secureTopic [2014-07-18 13:12:29,817] WARN Property topic is

Re: Review Request 23339: Patch for KAFKA-1507

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/23339/#review48397 --- Thanks for the patch and doing the rebasing. Some comments below.

[jira] [Updated] (KAFKA-1550) Patch review tool should use git format-patch to generate patch

[ https://issues.apache.org/jira/browse/KAFKA-1550?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-1550: Attachment: KAFKA-1550_2014-07-22_11:41:57.patch > Patch review tool should use git format-patch to generat

Re: Review Request 23692: Patch for KAFKA-1550

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

[jira] [Created] (KAFKA-1555) provide strong consistency with reasonable availability

Jiang Wu created KAFKA-1555: --- Summary: provide strong consistency with reasonable availability Key: KAFKA-1555 URL: https://issues.apache.org/jira/browse/KAFKA-1555 Project: Kafka Issue Type: Impro

Re: Review Request 23692: Patch for KAFKA-1550

> On July 22, 2014, 6:30 p.m., Neha Narkhede wrote: > > kafka-patch-review.py, line 120 > > > > > > formatted patch is a little misleading and is a git specific command. > > diff is easier to understand. So I'd recomm

[jira] [Commented] (KAFKA-1550) Patch review tool should use git format-patch to generate patch

[ https://issues.apache.org/jira/browse/KAFKA-1550?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14070673#comment-14070673 ] Dong Lin commented on KAFKA-1550: - Updated reviewboard https://reviews.apache.org/r/23692/

[jira] [Commented] (KAFKA-1070) Auto-assign node id

[ https://issues.apache.org/jira/browse/KAFKA-1070?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14070658#comment-14070658 ] Sriharsha Chintalapani commented on KAFKA-1070: --- Updated reviewboard https:/

[jira] [Updated] (KAFKA-1070) Auto-assign node id

[ https://issues.apache.org/jira/browse/KAFKA-1070?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sriharsha Chintalapani updated KAFKA-1070: -- Attachment: KAFKA-1070_2014-07-22_11:34:18.patch > Auto-assign node id > --

Re: Review Request 23702: Patch for KAFKA-1070

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

Re: Review Request 23655: Patch for KAFKA-687

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/23655/#review48165 --- core/src/main/scala/kafka/consumer/ConsumerConfig.scala

Re: Review Request 23692: Patch for KAFKA-1550

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/23692/#review48392 --- Looks good. Thanks for improving our tools. I have a minor comment.

[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=14070642#comment-14070642 ] Dmitry Bugaychenko commented on KAFKA-1414: --- "data dir" and "log dir" seems more

[jira] [Comment Edited] (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=14070634#comment-14070634 ] Anton Karamanov edited comment on KAFKA-1414 at 7/22/14 6:26 PM: ---

[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=14070634#comment-14070634 ] Anton Karamanov commented on KAFKA-1414: Second approach seems fine to me as well.

[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=14070630#comment-14070630 ] Neha Narkhede commented on KAFKA-1476: -- Thanks for the updated patch [~balaji.sesha..

[jira] [Updated] (KAFKA-1550) Patch review tool should use git format-patch to generate patch

[ https://issues.apache.org/jira/browse/KAFKA-1550?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-1550: Description: 1) kafka-patch-review.py uses git-diff to generate patch for jira ticket. The resulting patch

[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=14070585#comment-14070585 ] Jun Rao commented on KAFKA-1462: Thanks for the reviews. Committed the followup patch. >

[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=14070555#comment-14070555 ] Dmitry Bugaychenko commented on KAFKA-1414: --- We would prefer the second approach

[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 ] Joe Stein updated KAFKA-1414: - Fix Version/s: 0.8.2 > Speedup broker startup after hard reset > ---

[jira] [Commented] (KAFKA-1507) Using GetOffsetShell against non-existent topic creates the topic unintentionally

[ https://issues.apache.org/jira/browse/KAFKA-1507?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14070551#comment-14070551 ] Sriharsha Chintalapani commented on KAFKA-1507: --- Updated reviewboard https:/

[jira] [Updated] (KAFKA-1507) Using GetOffsetShell against non-existent topic creates the topic unintentionally

[ https://issues.apache.org/jira/browse/KAFKA-1507?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sriharsha Chintalapani updated KAFKA-1507: -- Attachment: KAFKA-1507_2014-07-22_10:27:45.patch > Using GetOffsetShell against

Re: Review Request 23339: Patch for KAFKA-1507

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/23339/ --- (Updated July 22, 2014, 5:27 p.m.) Review request for kafka. Bugs: KAFKA-1507

[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=14070542#comment-14070542 ] Jay Kreps commented on KAFKA-1414: -- Cool, that is a great speed-up either way. I'm fine

Re: Review Request 23767: Fix KAFKA-1430

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/23767/#review48283 --- Thanks for the patch. There are some unused imports. Detailed commen

[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=14070489#comment-14070489 ] Anton Karamanov commented on KAFKA-1414: Here are some measurements for 4 disks, e

Re: Review Request 23705: Addressing Jun's comments

> On July 21, 2014, 6:16 p.m., Guozhang Wang wrote: > > core/src/main/scala/kafka/tools/DumpLogSegments.scala, line 165 > > > > > > Would key also be null possibly? > > Manikumar Reddy O wrote: > This line is surr

[GitHub] kafka pull request: Clarify log expiry configuration options (for ...

GitHub user MarkRose opened a pull request: https://github.com/apache/kafka/pull/28 Clarify log expiry configuration options (for trunk) I spent a bit of time tracking down why files were being deleted before they reached log.retention.hours of age. It turns out that the time and si

[GitHub] kafka pull request: Clarify log deletion configuration options in ...

GitHub user MarkRose opened a pull request: https://github.com/apache/kafka/pull/27 Clarify log deletion configuration options in server.properties I spent a bit of time tracking down why files were being deleted before they reached log.retention.hours of age. It turns out that the

Re: Review Request 23705: Addressing Jun's comments

> On July 21, 2014, 6:16 p.m., Guozhang Wang wrote: > > core/src/main/scala/kafka/tools/DumpLogSegments.scala, line 165 > > > > > > Would key also be null possibly? This line is surrounded by if(msg.hasKey) check. ms

[jira] [Updated] (KAFKA-1189) kafka-server-stop.sh doesn't stop broker

[ https://issues.apache.org/jira/browse/KAFKA-1189?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Joe Stein updated KAFKA-1189: - Fix Version/s: 0.8.2 > kafka-server-stop.sh doesn't stop broker > ---

[jira] [Updated] (KAFKA-1425) provide logStartOffset in addition to LogEndOffset metric

[ https://issues.apache.org/jira/browse/KAFKA-1425?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Joe Stein updated KAFKA-1425: - Fix Version/s: 0.8.2 > provide logStartOffset in addition to LogEndOffset metric > --

[jira] [Updated] (KAFKA-1446) Consumer metrics for rebalance

[ https://issues.apache.org/jira/browse/KAFKA-1446?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Joe Stein updated KAFKA-1446: - Fix Version/s: 0.8.2 > Consumer metrics for rebalance > -- > >

[jira] [Updated] (KAFKA-1328) Add new consumer APIs

[ https://issues.apache.org/jira/browse/KAFKA-1328?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Joe Stein updated KAFKA-1328: - Fix Version/s: 0.8.2 > Add new consumer APIs > - > > Key: KAFKA-1328

[jira] [Updated] (KAFKA-1442) RBTools post-review is deprecated

[ https://issues.apache.org/jira/browse/KAFKA-1442?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Joe Stein updated KAFKA-1442: - Fix Version/s: 0.8.2 > RBTools post-review is deprecated > - > >

[jira] [Updated] (KAFKA-1431) ConsoleConsumer - Option to clean zk consumer path

[ https://issues.apache.org/jira/browse/KAFKA-1431?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Joe Stein updated KAFKA-1431: - Fix Version/s: 0.8.2 > ConsoleConsumer - Option to clean zk consumer path > -

[jira] [Updated] (KAFKA-1179) createMessageStreams() in javaapi.ZookeeperConsumerConnector does not throw

[ https://issues.apache.org/jira/browse/KAFKA-1179?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Joe Stein updated KAFKA-1179: - Fix Version/s: 0.8.2 > createMessageStreams() in javaapi.ZookeeperConsumerConnector does not throw >

[jira] [Updated] (KAFKA-1238) New producer hangs in a loop detecting metadata for auto created topics

[ https://issues.apache.org/jira/browse/KAFKA-1238?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Joe Stein updated KAFKA-1238: - Fix Version/s: 0.8.2 > New producer hangs in a loop detecting metadata for auto created topics >

[jira] [Updated] (KAFKA-1444) kafka.javaapi.TopicMetadata and PartitionMetadata doesn't forward the toString method

[ https://issues.apache.org/jira/browse/KAFKA-1444?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Joe Stein updated KAFKA-1444: - Fix Version/s: 0.8.2 > kafka.javaapi.TopicMetadata and PartitionMetadata doesn't forward the > toString

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

[ https://issues.apache.org/jira/browse/KAFKA-1300?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Joe Stein updated KAFKA-1300: - Fix Version/s: (was: 0.8.1) 0.8.2 > Added WaitForReplaction admin tool. >

[jira] [Updated] (KAFKA-1459) kafka.tools.ConsumerOffsetChecker throws NoNodeException

[ https://issues.apache.org/jira/browse/KAFKA-1459?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Joe Stein updated KAFKA-1459: - Fix Version/s: 0.8.2 > kafka.tools.ConsumerOffsetChecker throws NoNodeException > ---

[jira] [Updated] (KAFKA-1469) Util.abs function does not return correct absolute values for negative values

[ https://issues.apache.org/jira/browse/KAFKA-1469?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Joe Stein updated KAFKA-1469: - Fix Version/s: 0.8.2 > Util.abs function does not return correct absolute values for negative values > --

[jira] [Updated] (KAFKA-1443) Add delete topic to topic commands and update DeleteTopicCommand

[ https://issues.apache.org/jira/browse/KAFKA-1443?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Joe Stein updated KAFKA-1443: - Fix Version/s: 0.8.2 > Add delete topic to topic commands and update DeleteTopicCommand > ---

[jira] [Updated] (KAFKA-1491) ConsumerMetadataResponse is not read completely

[ https://issues.apache.org/jira/browse/KAFKA-1491?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Joe Stein updated KAFKA-1491: - Fix Version/s: 0.8.2 > ConsumerMetadataResponse is not read completely >

[jira] [Updated] (KAFKA-1316) Refactor Sender

[ https://issues.apache.org/jira/browse/KAFKA-1316?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Joe Stein updated KAFKA-1316: - Fix Version/s: 0.8.2 > Refactor Sender > --- > > Key: KAFKA-1316 >

[jira] [Updated] (KAFKA-1298) Controlled shutdown tool doesn't seem to work out of the box

[ https://issues.apache.org/jira/browse/KAFKA-1298?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Joe Stein updated KAFKA-1298: - Fix Version/s: 0.8.2 > Controlled shutdown tool doesn't seem to work out of the box > ---

[jira] [Updated] (KAFKA-1512) Limit the maximum number of connections per ip address

[ https://issues.apache.org/jira/browse/KAFKA-1512?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Joe Stein updated KAFKA-1512: - Fix Version/s: 0.8.2 > Limit the maximum number of connections per ip address > -

[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 ] Joe Stein updated KAFKA-1519: - Fix Version/s: 0.8.2 > Console consumer: expose configuration option to enable/disable writing the > lin

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

[ https://issues.apache.org/jira/browse/KAFKA-1535?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Joe Stein updated KAFKA-1535: - Affects Version/s: (was: 0.8.2) 0.8.1.1 Fix Version/s: 0.8.2 > return

[jira] [Updated] (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:all-tabpanel ] Joe Stein updated KAFKA-1539: - Fix Version/s: 0.8.2 > Due to OS caching Kafka might loose offset files which causes full reset of > dat

[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=14070274#comment-14070274 ] Dmitry Bugaychenko commented on KAFKA-1539: --- With fileOutputStream.getFD.sync()