Build failed in Jenkins: Kafka-trunk #215

See Changes: [junrao] kafka-1513; Cleanup KafkaServerStartable code; patched by Evgeny Vereshchagin; reviewed by Jun Rao -- [...truncated 1667 lines...] at kafka.integration.KafkaServerTestH

Build failed in Jenkins: Kafka-trunk #214

See Changes: [junrao] kafka-1503; all partitions are using same broker as their leader after broker is down; patched by Jianwen Wang; reviewed by Guozhang Wang and Jun Rao -- [...truncated 1788 line

[jira] [Resolved] (KAFKA-1513) Cleanup KafkaServerStartable code

[ https://issues.apache.org/jira/browse/KAFKA-1513?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao resolved KAFKA-1513. Resolution: Fixed Fix Version/s: 0.8.2 Assignee: Evgeny Vereshchagin Thanks for the patch.

[jira] [Updated] (KAFKA-1503) all partitions are using same broker as their leader after broker is down

[ https://issues.apache.org/jira/browse/KAFKA-1503?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-1503: --- Resolution: Fixed Fix Version/s: (was: 0.8.1.1) 0.8.2 Assignee: Jianwen

[jira] [Created] (KAFKA-1518) KafkaMetricsReporter prevents Kafka from starting if the custom reporter throws an exception

Daniel Compton created KAFKA-1518: - Summary: KafkaMetricsReporter prevents Kafka from starting if the custom reporter throws an exception Key: KAFKA-1518 URL: https://issues.apache.org/jira/browse/KAFKA-1518

[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 ] Daniel Compton updated KAFKA-1517: -- Description: When running the producer performance test without providing a messages argument,

[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 ] Daniel Compton updated KAFKA-1517: -- Description: When running the producer performance test without providing a messages argument,

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

Daniel Compton created KAFKA-1517: - Summary: Messages is a required argument to Producer Performance Test Key: KAFKA-1517 URL: https://issues.apache.org/jira/browse/KAFKA-1517 Project: Kafka

[jira] [Updated] (KAFKA-1516) Producer Performance Test sends messages with bytes of 0x0

[ https://issues.apache.org/jira/browse/KAFKA-1516?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Compton updated KAFKA-1516: -- Description: The producer performance test in Kafka sends messages with either [0x0 bytes|http

[jira] [Updated] (KAFKA-1516) Producer Performance Test sends messages with bytes of 0x0

[ https://issues.apache.org/jira/browse/KAFKA-1516?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Compton updated KAFKA-1516: -- Description: The producer performance test in Kafka sends messages with either [0x0 bytes|http

[jira] [Created] (KAFKA-1516) Producer Performance Test sends messages with bytes of 0x0

Daniel Compton created KAFKA-1516: - Summary: Producer Performance Test sends messages with bytes of 0x0 Key: KAFKA-1516 URL: https://issues.apache.org/jira/browse/KAFKA-1516 Project: Kafka Is

[jira] [Updated] (KAFKA-1513) Cleanup KafkaServerStartable code

[ https://issues.apache.org/jira/browse/KAFKA-1513?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Evgeny Vereshchagin updated KAFKA-1513: --- Attachment: KAFKA-1513.patch > Cleanup KafkaServerStartable code > --

[jira] [Commented] (KAFKA-1513) Cleanup KafkaServerStartable code

[ https://issues.apache.org/jira/browse/KAFKA-1513?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14051001#comment-14051001 ] Evgeny Vereshchagin commented on KAFKA-1513: Created reviewboard https://revie

Review Request 23255: Patch for KAFKA-1513

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

[jira] [Commented] (KAFKA-1196) java.lang.IllegalArgumentException Buffer.limit on FetchResponse.scala + 33

[ https://issues.apache.org/jira/browse/KAFKA-1196?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14050999#comment-14050999 ] DashengJu commented on KAFKA-1196: -- Thanks for your reply. I will try to increase num.re

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

Guozhang Wang created KAFKA-1515: Summary: Wake-up Sender upon blocked on fetching leader metadata Key: KAFKA-1515 URL: https://issues.apache.org/jira/browse/KAFKA-1515 Project: Kafka Issue T

[jira] [Created] (KAFKA-1514) Update Kafka trunk version number

Jakob Homan created KAFKA-1514: -- Summary: Update Kafka trunk version number Key: KAFKA-1514 URL: https://issues.apache.org/jira/browse/KAFKA-1514 Project: Kafka Issue Type: Bug Repor

[jira] [Updated] (KAFKA-1308) Publish jar of test utilities to Maven

[ https://issues.apache.org/jira/browse/KAFKA-1308?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jakob Homan updated KAFKA-1308: --- Resolution: Fixed Status: Resolved (was: Patch Available) > Publish jar of test utilities to

[jira] [Updated] (KAFKA-1308) Publish jar of test utilities to Maven

[ https://issues.apache.org/jira/browse/KAFKA-1308?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jakob Homan updated KAFKA-1308: --- Attachment: KAFKA-1308-trunk.patch Resolved conflict (in version number; also dropped the -INCUBATING

[jira] [Commented] (KAFKA-1513) Cleanup KafkaServerStartable code

[ https://issues.apache.org/jira/browse/KAFKA-1513?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14050623#comment-14050623 ] Evgeny Vereshchagin commented on KAFKA-1513: Submit new [patch|https://issues

[jira] [Updated] (KAFKA-1513) Cleanup KafkaServerStartable code

[ https://issues.apache.org/jira/browse/KAFKA-1513?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Evgeny Vereshchagin updated KAFKA-1513: --- Attachment: cleanup-kafkaserverstartable-code-v2.patch > Cleanup KafkaServerStartable

Transactional messaging in Kafka

A couple of folks have been thinking through adding transactional support to Kafka - close to, but much more general than the idempotent producer. Rather than put too many details in this email I thought I would send out a wiki link to the write-up and proposal: https://cwiki.apache.org/confluence

[jira] [Comment Edited] (KAFKA-1513) Cleanup KafkaServerStartable code

[ https://issues.apache.org/jira/browse/KAFKA-1513?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14050303#comment-14050303 ] Evgeny Vereshchagin edited comment on KAFKA-1513 at 7/2/14 4:41 PM:

[jira] [Commented] (KAFKA-1513) Cleanup KafkaServerStartable code

[ https://issues.apache.org/jira/browse/KAFKA-1513?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14050303#comment-14050303 ] Evgeny Vereshchagin commented on KAFKA-1513: Yes, It's ok. I want to remove ty

[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=14050258#comment-14050258 ] Jun Rao commented on KAFKA-1507: Both the produce and the consumer client will issue Topic

[jira] [Commented] (KAFKA-1513) Cleanup KafkaServerStartable code

[ https://issues.apache.org/jira/browse/KAFKA-1513?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14050261#comment-14050261 ] Evgeny Vereshchagin commented on KAFKA-1513: Looks like server could be just v

[jira] [Resolved] (KAFKA-1511) Malformated link and consumer/producer mixup in documentation

[ https://issues.apache.org/jira/browse/KAFKA-1511?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao resolved KAFKA-1511. Resolution: Fixed Fix Version/s: 0.8.2 Assignee: Jun Rao Thanks for pointing this out. Fixe

[jira] [Resolved] (KAFKA-1204) Add KAFKA_LOG_DIR to allow LOG_DIR to be outside of code dir

[ https://issues.apache.org/jira/browse/KAFKA-1204?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao resolved KAFKA-1204. Resolution: Not a Problem Fix Version/s: 0.8.2 Already fixed in trunk. > Add KAFKA_LOG_DIR to allow

[jira] [Commented] (KAFKA-1513) Cleanup KafkaServerStartable code

[ https://issues.apache.org/jira/browse/KAFKA-1513?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14050221#comment-14050221 ] Jun Rao commented on KAFKA-1513: Thanks for the patch. Could server be just val? > Cleanu

[jira] [Commented] (KAFKA-1196) java.lang.IllegalArgumentException Buffer.limit on FetchResponse.scala + 33

[ https://issues.apache.org/jira/browse/KAFKA-1196?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14050065#comment-14050065 ] Jun Rao commented on KAFKA-1196: You can do one or more of the following to get around thi

[jira] [Commented] (KAFKA-1196) java.lang.IllegalArgumentException Buffer.limit on FetchResponse.scala + 33

[ https://issues.apache.org/jira/browse/KAFKA-1196?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14049766#comment-14049766 ] DashengJu commented on KAFKA-1196: -- I have encounter this problem. I have many topics an