[jira] [Created] (KAFKA-1273) Brokers should make sure replica.fetch.max.bytes >= message.max.bytes

Dong Zhong created KAFKA-1273: - Summary: Brokers should make sure replica.fetch.max.bytes >= message.max.bytes Key: KAFKA-1273 URL: https://issues.apache.org/jira/browse/KAFKA-1273 Project: Kafka

[jira] [Updated] (KAFKA-1274) gradle.properties needs the variables used in the build.gradle

[ https://issues.apache.org/jira/browse/KAFKA-1274?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Joe Stein updated KAFKA-1274: - Priority: Blocker (was: Major) > gradle.properties needs the variables used in the build.gradle > --

[jira] [Created] (KAFKA-1274) gradle.properties needs the variables used in the build.gradle

Joe Stein created KAFKA-1274: Summary: gradle.properties needs the variables used in the build.gradle Key: KAFKA-1274 URL: https://issues.apache.org/jira/browse/KAFKA-1274 Project: Kafka Issue T

Review Request 18269: Patch for KAFKA-1274

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

[jira] [Commented] (KAFKA-1274) gradle.properties needs the variables used in the build.gradle

[ https://issues.apache.org/jira/browse/KAFKA-1274?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13905531#comment-13905531 ] Joe Stein commented on KAFKA-1274: -- Created reviewboard https://reviews.apache.org/r/1826

[jira] [Updated] (KAFKA-1274) gradle.properties needs the variables used in the build.gradle

[ https://issues.apache.org/jira/browse/KAFKA-1274?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Joe Stein updated KAFKA-1274: - Attachment: KAFKA-1274.patch > gradle.properties needs the variables used in the build.gradle > -

[jira] [Updated] (KAFKA-1274) gradle.properties needs the variables used in the build.gradle

[ https://issues.apache.org/jira/browse/KAFKA-1274?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Joe Stein updated KAFKA-1274: - Status: Patch Available (was: Open) > gradle.properties needs the variables used in the build.gradle > -

Re: Review Request 18269: Patch for KAFKA-1274

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/18269/#review34865 --- Ship it! Ship It! - Jun Rao On Feb. 19, 2014, 3:06 p.m., Joe Ste

Review Request 18273: Patch for KAFKA-1271

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

[jira] [Commented] (KAFKA-1271) controller logs exceptions during ZK session expiration

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

[jira] [Updated] (KAFKA-1271) controller logs exceptions during ZK session expiration

[ https://issues.apache.org/jira/browse/KAFKA-1271?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-1271: --- Attachment: KAFKA-1271.patch > controller logs exceptions during ZK session expiration >

[jira] [Updated] (KAFKA-1274) gradle.properties needs the variables used in the build.gradle

[ https://issues.apache.org/jira/browse/KAFKA-1274?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Joe Stein updated KAFKA-1274: - Resolution: Fixed Status: Resolved (was: Patch Available) double committed on 0.8.1 and trunk >

[jira] [Resolved] (KAFKA-1255) Offset in RecordMetadata is Incorrect with New Producer Ack = -1

[ https://issues.apache.org/jira/browse/KAFKA-1255?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-1255. -- Resolution: Duplicate This issue has been fixed in KAFKA-1260 > Offset in RecordMetadata is In

[jira] [Created] (KAFKA-1275) fixes for quickstart documentation

Evan Zacks created KAFKA-1275: - Summary: fixes for quickstart documentation Key: KAFKA-1275 URL: https://issues.apache.org/jira/browse/KAFKA-1275 Project: Kafka Issue Type: Bug Componen

[jira] [Updated] (KAFKA-1275) fixes for quickstart documentation

[ https://issues.apache.org/jira/browse/KAFKA-1275?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Evan Zacks updated KAFKA-1275: -- Attachment: KAFKA-1275-quickstart-doc.patch Patch against 08/quickstart.html > fixes for quickstart do

[jira] [Commented] (KAFKA-1275) fixes for quickstart documentation

[ https://issues.apache.org/jira/browse/KAFKA-1275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13905786#comment-13905786 ] Evan Zacks commented on KAFKA-1275: --- Includes some fixes to minor typos and inconsistent

[jira] [Updated] (KAFKA-1275) fixes for quickstart documentation

[ https://issues.apache.org/jira/browse/KAFKA-1275?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Evan Zacks updated KAFKA-1275: -- Fix Version/s: 0.8.1 Labels: documentation (was: ) Status: Patch Available (was:

[jira] [Commented] (KAFKA-1252) Implement re-tries in new producer

[ https://issues.apache.org/jira/browse/KAFKA-1252?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13906077#comment-13906077 ] Guozhang Wang commented on KAFKA-1252: -- It needs to be BLOCK_ON_BUFFER_FULL_CONFIG no

Re: Review Request 18273: Patch for KAFKA-1271

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/18273/#review34929 --- Ship it! Ship It! - Guozhang Wang On Feb. 19, 2014, 3:57 p.m., J

Re: Review Request 18102: Integration Test for New Producer: Part II

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/18102/ --- (Updated Feb. 19, 2014, 9:49 p.m.) Review request for kafka. Bugs: KAFKA-1260

[jira] [Commented] (KAFKA-1252) Implement re-tries in new producer

[ https://issues.apache.org/jira/browse/KAFKA-1252?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13906144#comment-13906144 ] Jay Kreps commented on KAFKA-1252: -- I actually checked in a fix last night. > Implement

[jira] [Updated] (KAFKA-1260) Integration Test for New Producer Part II: Broker Failure Handling

[ https://issues.apache.org/jira/browse/KAFKA-1260?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-1260: - Attachment: KAFKA-1260_2014-02-19_13:49:19.patch > Integration Test for New Producer Part II: Bro

[jira] [Commented] (KAFKA-1260) Integration Test for New Producer Part II: Broker Failure Handling

[ https://issues.apache.org/jira/browse/KAFKA-1260?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13906145#comment-13906145 ] Guozhang Wang commented on KAFKA-1260: -- Updated reviewboard https://reviews.apache.or

Re: Review Request 18102: Integration Test for New Producer: Part II

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/18102/ --- (Updated Feb. 19, 2014, 9:51 p.m.) Review request for kafka. Bugs: KAFKA-1260

[jira] [Commented] (KAFKA-1252) Implement re-tries in new producer

[ https://issues.apache.org/jira/browse/KAFKA-1252?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13906151#comment-13906151 ] Guozhang Wang commented on KAFKA-1252: -- Cool, I will only change the integration test

[jira] [Commented] (KAFKA-1275) fixes for quickstart documentation

[ https://issues.apache.org/jira/browse/KAFKA-1275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13906173#comment-13906173 ] Guozhang Wang commented on KAFKA-1275: -- +1. Thanks for the patch. > fixes for quick

Re: Review Request 17671: Fix KAFKA-1235

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

[jira] [Updated] (KAFKA-1260) Integration Test for New Producer Part II: Broker Failure Handling

[ https://issues.apache.org/jira/browse/KAFKA-1260?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-1260: - Attachment: KAFKA-1260_2014-02-19_15:55:06.patch > Integration Test for New Producer Part II: Bro

[jira] [Commented] (KAFKA-1260) Integration Test for New Producer Part II: Broker Failure Handling

[ https://issues.apache.org/jira/browse/KAFKA-1260?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13906316#comment-13906316 ] Guozhang Wang commented on KAFKA-1260: -- Updated reviewboard https://reviews.apache.or

Re: Review Request 17671: Fix KAFKA-1235

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/17671/ --- (Updated Feb. 19, 2014, 11:57 p.m.) Review request for kafka. Bugs: KAFKA-123

Re: Review Request 17671: Fix KAFKA-1235

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/17671/ --- (Updated Feb. 19, 2014, 11:57 p.m.) Review request for kafka. Bugs: KAFKA-123

[jira] [Commented] (KAFKA-1235) Enable server to indefinitely retry on controlled shutdown

[ https://issues.apache.org/jira/browse/KAFKA-1235?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13906322#comment-13906322 ] Guozhang Wang commented on KAFKA-1235: -- Updated reviewboard https://reviews.apache.or

[jira] [Issue Comment Deleted] (KAFKA-1260) Integration Test for New Producer Part II: Broker Failure Handling

[ https://issues.apache.org/jira/browse/KAFKA-1260?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-1260: - Comment: was deleted (was: Updated reviewboard https://reviews.apache.org/r/17671/ against branc

[jira] [Commented] (KAFKA-1253) Implement compression in new producer

[ https://issues.apache.org/jira/browse/KAFKA-1253?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13906339#comment-13906339 ] Guozhang Wang commented on KAFKA-1253: -- It seems incremental compression would not be

[jira] [Commented] (KAFKA-1253) Implement compression in new producer

[ https://issues.apache.org/jira/browse/KAFKA-1253?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13906407#comment-13906407 ] Jay Kreps commented on KAFKA-1253: -- This will be tricky but is possible. Here are a coup

[jira] [Commented] (KAFKA-1253) Implement compression in new producer

[ https://issues.apache.org/jira/browse/KAFKA-1253?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13906422#comment-13906422 ] Jay Kreps commented on KAFKA-1253: -- Also the high-level idea I had for implementation was

Review Request 18299: Proposed In-place Compression on MemoryRecords

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

[jira] [Commented] (KAFKA-1253) Implement compression in new producer

[ https://issues.apache.org/jira/browse/KAFKA-1253?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13906532#comment-13906532 ] Guozhang Wang commented on KAFKA-1253: -- Created reviewboard https://reviews.apache.or

[jira] [Commented] (KAFKA-1253) Implement compression in new producer

[ https://issues.apache.org/jira/browse/KAFKA-1253?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13906533#comment-13906533 ] Guozhang Wang commented on KAFKA-1253: -- Uploaded a first-step patch which illustrate

[jira] [Updated] (KAFKA-1253) Implement compression in new producer

[ https://issues.apache.org/jira/browse/KAFKA-1253?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-1253: - Attachment: KAFKA-1253.patch > Implement compression in new producer > --

[jira] [Commented] (KAFKA-1253) Implement compression in new producer

[ https://issues.apache.org/jira/browse/KAFKA-1253?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13906544#comment-13906544 ] Guozhang Wang commented on KAFKA-1253: -- One note is that in this preliminary patch I

Re: Review Request 18299: Proposed In-place Compression on MemoryRecords

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/18299/#review34977 --- clients/src/main/java/org/apache/kafka/common/record/CompressedMemo

[jira] [Commented] (KAFKA-1260) Integration Test for New Producer Part II: Broker Failure Handling

[ https://issues.apache.org/jira/browse/KAFKA-1260?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13906580#comment-13906580 ] Jay Kreps commented on KAFKA-1260: -- I think this approach may work but we have to work ou

[jira] [Commented] (KAFKA-1275) fixes for quickstart documentation

[ https://issues.apache.org/jira/browse/KAFKA-1275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13906597#comment-13906597 ] Jun Rao commented on KAFKA-1275: Evan, Thanks for the patch. We will have to wait until 0

[jira] [Commented] (KAFKA-1254) remove vestigial sbt

[ https://issues.apache.org/jira/browse/KAFKA-1254?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13906600#comment-13906600 ] Jun Rao commented on KAFKA-1254: Joe, Do you want to commit this? > remove vestigial sbt

[jira] [Commented] (KAFKA-1254) remove vestigial sbt

[ https://issues.apache.org/jira/browse/KAFKA-1254?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13906605#comment-13906605 ] Joe Stein commented on KAFKA-1254: -- Yes! will remove the TODO also. > remove vestigial s

[jira] [Updated] (KAFKA-1260) Integration Test for New Producer Part II: Broker Failure Handling

[ https://issues.apache.org/jira/browse/KAFKA-1260?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jay Kreps updated KAFKA-1260: - Attachment: KAFKA-1260-fix.patch Hey Guozhang, this patch fixes two issues that effected that test. Essen

[jira] [Commented] (KAFKA-1275) fixes for quickstart documentation

[ https://issues.apache.org/jira/browse/KAFKA-1275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13906619#comment-13906619 ] Jay Kreps commented on KAFKA-1275: -- I guess the question is whether we want to fork the d

[jira] [Commented] (KAFKA-1253) Implement compression in new producer

[ https://issues.apache.org/jira/browse/KAFKA-1253?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13906620#comment-13906620 ] Jay Kreps commented on KAFKA-1253: -- I think this approach may work but we have to work ou

[jira] [Issue Comment Deleted] (KAFKA-1260) Integration Test for New Producer Part II: Broker Failure Handling

[ https://issues.apache.org/jira/browse/KAFKA-1260?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jay Kreps updated KAFKA-1260: - Comment: was deleted (was: I think this approach may work but we have to work out a few issues to know.

[jira] [Updated] (KAFKA-1254) remove vestigial sbt

[ https://issues.apache.org/jira/browse/KAFKA-1254?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Joe Stein updated KAFKA-1254: - Resolution: Fixed Status: Resolved (was: Patch Available) double committed to 0.8.1 and trunk f

[jira] [Resolved] (KAFKA-1243) Gradle issues for release

[ https://issues.apache.org/jira/browse/KAFKA-1243?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Joe Stein resolved KAFKA-1243. -- Resolution: Fixed everything related to this has been taken care of and is committed to 0.8.1 and trun

Re: Review Request 18199: Patch for KAFKA-1252

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/18199/#review34981 --- clients/src/main/java/org/apache/kafka/clients/producer/internals/S

[jira] [Commented] (KAFKA-1275) fixes for quickstart documentation

[ https://issues.apache.org/jira/browse/KAFKA-1275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13906635#comment-13906635 ] Joe Stein commented on KAFKA-1275: -- +1 > fixes for quickstart documentation > --

[DISCUSS] 0.8.1 Release

I wanted to start a thread prior to starting the vote for the 0.8.1 release. There are 3 open patches still pending https://issues.apache.org/jira/issues/?jql=project%20%3D%20KAFKA%20AND%20fixVersion%20%3D%20%220.8.1%22%20AND%20status%20%3D%20%22Patch%20Available%22%20ORDER%20BY%20priority%20DESC

Re: [DISCUSS] 0.8.1 Release

Hi, Joe, I agree with you that KAFKA-1180 and KAFKA-1210 are not blockers and can be moved to 0.8.2. I'd like to check in KAFKA-1271. It's a simple fix and improves the logging. Sriram has a delta patch in KAFKA-930 that was waiting for the delete topic patch to be checked in. I think once the

[jira] [Updated] (KAFKA-1271) controller logs exceptions during ZK session expiration

[ https://issues.apache.org/jira/browse/KAFKA-1271?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Joe Stein updated KAFKA-1271: - Fix Version/s: 0.8.1 > controller logs exceptions during ZK session expiration >

[jira] [Updated] (KAFKA-930) Integrate preferred replica election logic into kafka

[ https://issues.apache.org/jira/browse/KAFKA-930?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Joe Stein updated KAFKA-930: Fix Version/s: (was: 0.9.0) 0.8.1 > Integrate preferred replica election logic into k

[jira] [Updated] (KAFKA-1210) Windows Bat files are not working properly

[ https://issues.apache.org/jira/browse/KAFKA-1210?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Joe Stein updated KAFKA-1210: - Fix Version/s: (was: 0.8.1) 0.8.2 > Windows Bat files are not working properly > -

Re: [DISCUSS] 0.8.1 Release

sounds good, I updated JIRA to reflect the below On Thu, Feb 20, 2014 at 1:17 AM, Jun Rao wrote: > Hi, Joe, > > I agree with you that KAFKA-1180 and KAFKA-1210 are not blockers and can be > moved to 0.8.2. > > I'd like to check in KAFKA-1271. It's a simple fix and improves the > logging. > > Sri

[jira] [Updated] (KAFKA-1180) WhiteList topic filter gets a NullPointerException on complex Regex

[ https://issues.apache.org/jira/browse/KAFKA-1180?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Joe Stein updated KAFKA-1180: - Fix Version/s: (was: 0.8.1) 0.8.2 > WhiteList topic filter gets a NullPointerExcep