[jira] [Commented] (KAFKA-762) Improve second replica assignment

[ https://issues.apache.org/jira/browse/KAFKA-762?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13584461#comment-13584461 ] Guozhang Wang commented on KAFKA-762: - I think that as long as the secondShift is

[jira] [Commented] (KAFKA-763) Add an option to replica from the largest offset during unclean leader election

[ https://issues.apache.org/jira/browse/KAFKA-763?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13584479#comment-13584479 ] Guozhang Wang commented on KAFKA-763: - Can these cover all the cases (the bars

[jira] [Comment Edited] (KAFKA-763) Add an option to replica from the largest offset during unclean leader election

[ https://issues.apache.org/jira/browse/KAFKA-763?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13584479#comment-13584479 ] Guozhang Wang edited comment on KAFKA-763 at 2/22/13 5:51 PM: --

[jira] [Comment Edited] (KAFKA-763) Add an option to replica from the largest offset during unclean leader election

[ https://issues.apache.org/jira/browse/KAFKA-763?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13584479#comment-13584479 ] Guozhang Wang edited comment on KAFKA-763 at 2/22/13 5:51 PM: --

[jira] [Updated] (KAFKA-957) MirrorMaker needs to preserve the key in the source cluster

[ https://issues.apache.org/jira/browse/KAFKA-957?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-957: Assignee: Guozhang Wang MirrorMaker needs to preserve the key in the source cluster

[jira] [Commented] (KAFKA-957) MirrorMaker needs to preserve the key in the source cluster

[ https://issues.apache.org/jira/browse/KAFKA-957?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13702667#comment-13702667 ] Guozhang Wang commented on KAFKA-957: - The proposed design is the following: 1. Keep

[jira] [Commented] (KAFKA-959) DefaultEventHandler can send more produce requests than necesary

[ https://issues.apache.org/jira/browse/KAFKA-959?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13702718#comment-13702718 ] Guozhang Wang commented on KAFKA-959: - Proposed code change: 1. Add a MapTopic,

[jira] [Created] (KAFKA-967) Use key range in ProducerPerformance

Guozhang Wang created KAFKA-967: --- Summary: Use key range in ProducerPerformance Key: KAFKA-967 URL: https://issues.apache.org/jira/browse/KAFKA-967 Project: Kafka Issue Type: Improvement

[jira] [Updated] (KAFKA-967) Use key range in ProducerPerformance

[ https://issues.apache.org/jira/browse/KAFKA-967?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-967: Attachment: KAFKA-967.v1.patch 1. Add messageKeyRange to ProducerPerfConfig 2. In

[jira] [Issue Comment Deleted] (KAFKA-967) Use key range in ProducerPerformance

[ https://issues.apache.org/jira/browse/KAFKA-967?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-967: Comment: was deleted (was: 1. Add messageKeyRange to ProducerPerfConfig 2. In

[jira] [Updated] (KAFKA-967) Use key range in ProducerPerformance

[ https://issues.apache.org/jira/browse/KAFKA-967?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-967: Status: Patch Available (was: Open) 1. Add messageKeyRange to ProducerPerfConfig 2. In

[jira] [Updated] (KAFKA-959) DefaultEventHandler can send more produce requests than necesary

[ https://issues.apache.org/jira/browse/KAFKA-959?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-959: Assignee: Guozhang Wang DefaultEventHandler can send more produce requests than necesary

[jira] [Commented] (KAFKA-969) Need to prevent failure of rebalance when there are no brokers available when consumer comes up

[ https://issues.apache.org/jira/browse/KAFKA-969?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13705484#comment-13705484 ] Guozhang Wang commented on KAFKA-969: - I think KAFKA-956 is orthogonal to this JIRA. It

[jira] [Commented] (KAFKA-969) Need to prevent failure of rebalance when there are no brokers available when consumer comes up

[ https://issues.apache.org/jira/browse/KAFKA-969?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13705954#comment-13705954 ] Guozhang Wang commented on KAFKA-969: - I think this is related to how we would enforce

[jira] [Updated] (KAFKA-957) MirrorMaker needs to preserve the key in the source cluster

[ https://issues.apache.org/jira/browse/KAFKA-957?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-957: Attachment: KAFKA-957.v1.patch 4. Add a ByteArrayPartitioner since Array[Byte].hashCode will result

[jira] [Updated] (KAFKA-957) MirrorMaker needs to preserve the key in the source cluster

[ https://issues.apache.org/jira/browse/KAFKA-957?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-957: Status: Patch Available (was: Open) MirrorMaker needs to preserve the key in the source

[jira] [Commented] (KAFKA-347) change number of partitions of a topic online

[ https://issues.apache.org/jira/browse/KAFKA-347?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13707434#comment-13707434 ] Guozhang Wang commented on KAFKA-347: - A few comments: 1. In addPartitions function,

[jira] [Updated] (KAFKA-967) Use key range in ProducerPerformance

[ https://issues.apache.org/jira/browse/KAFKA-967?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-967: Attachment: KAFKA-967.v2.patch Use key range in ProducerPerformance

[jira] [Created] (KAFKA-976) Order-Preserving Mirror Maker Testcase

Guozhang Wang created KAFKA-976: --- Summary: Order-Preserving Mirror Maker Testcase Key: KAFKA-976 URL: https://issues.apache.org/jira/browse/KAFKA-976 Project: Kafka Issue Type: Test

[jira] [Commented] (KAFKA-967) Use key range in ProducerPerformance

[ https://issues.apache.org/jira/browse/KAFKA-967?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13710046#comment-13710046 ] Guozhang Wang commented on KAFKA-967: - 4. Change key type from Integer to ByteArray in

[jira] [Commented] (KAFKA-976) Order-Preserving Mirror Maker Testcase

[ https://issues.apache.org/jira/browse/KAFKA-976?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13710361#comment-13710361 ] Guozhang Wang commented on KAFKA-976: - +1, passed test with the above steps.

[jira] [Updated] (KAFKA-957) MirrorMaker needs to preserve the key in the source cluster

[ https://issues.apache.org/jira/browse/KAFKA-957?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-957: Attachment: KAFKA-957.v2.patch 5. Use java.util.Arrays.hashCode to determine which producer to send

[jira] [Updated] (KAFKA-957) MirrorMaker needs to preserve the key in the source cluster

[ https://issues.apache.org/jira/browse/KAFKA-957?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-957: Attachment: KAFKA-957.v2.patch MirrorMaker needs to preserve the key in the source cluster

[jira] [Updated] (KAFKA-957) MirrorMaker needs to preserve the key in the source cluster

[ https://issues.apache.org/jira/browse/KAFKA-957?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-957: Attachment: KAFKA-957.v3.patch Thanks for the comment. For the first comment, since I needed to

[jira] [Commented] (KAFKA-925) Add optional partition key override in producer

[ https://issues.apache.org/jira/browse/KAFKA-925?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13711690#comment-13711690 ] Guozhang Wang commented on KAFKA-925: - Hi Jay, In the DefaultEventHandler, only the

[jira] [Commented] (KAFKA-983) Expose cleanshutdown method in MirrorMaker at the object level

[ https://issues.apache.org/jira/browse/KAFKA-983?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13715678#comment-13715678 ] Guozhang Wang commented on KAFKA-983: - +1. Looks good to me. Expose

[jira] [Created] (KAFKA-984) Avoid a full rebalance in cases when a new topic is discovered but container/broker set stay the same

Guozhang Wang created KAFKA-984: --- Summary: Avoid a full rebalance in cases when a new topic is discovered but container/broker set stay the same Key: KAFKA-984 URL: https://issues.apache.org/jira/browse/KAFKA-984

[jira] [Commented] (KAFKA-984) Avoid a full rebalance in cases when a new topic is discovered but container/broker set stay the same

[ https://issues.apache.org/jira/browse/KAFKA-984?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13715843#comment-13715843 ] Guozhang Wang commented on KAFKA-984: - Approach: 1. In

[jira] [Commented] (KAFKA-984) Avoid a full rebalance in cases when a new topic is discovered but container/broker set stay the same

[ https://issues.apache.org/jira/browse/KAFKA-984?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13715900#comment-13715900 ] Guozhang Wang commented on KAFKA-984: - Following Sriram's comments, I am trying to

[jira] [Updated] (KAFKA-982) Logo for Kafka

[ https://issues.apache.org/jira/browse/KAFKA-982?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-982: Attachment: 301.png Logo for Kafka -- Key: KAFKA-982

[jira] [Updated] (KAFKA-984) Avoid a full rebalance in cases when a new topic is discovered but container/broker set stay the same

[ https://issues.apache.org/jira/browse/KAFKA-984?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-984: Status: Patch Available (was: Open) Avoid a full rebalance in cases when a new topic is

[jira] [Updated] (KAFKA-984) Avoid a full rebalance in cases when a new topic is discovered but container/broker set stay the same

[ https://issues.apache.org/jira/browse/KAFKA-984?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-984: Attachment: KAFKA-984.v1.patch Avoid a full rebalance in cases when a new topic is discovered

[jira] [Updated] (KAFKA-984) Avoid a full rebalance in cases when a new topic is discovered but container/broker set stay the same

[ https://issues.apache.org/jira/browse/KAFKA-984?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-984: Attachment: KAFKA-984.v2.patch Added one more unit test in ZookeeperConsumerConnectorTest for

[jira] [Updated] (KAFKA-957) MirrorMaker needs to preserve the key in the source cluster

[ https://issues.apache.org/jira/browse/KAFKA-957?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-957: Attachment: KAFKA-957.v4.patch 7. Use Utils.abs to make sure the result of the hashCode function

[jira] [Updated] (KAFKA-959) DefaultEventHandler can send more produce requests than necesary

[ https://issues.apache.org/jira/browse/KAFKA-959?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-959: Status: Patch Available (was: Open) DefaultEventHandler can send more produce requests than

[jira] [Updated] (KAFKA-959) DefaultEventHandler can send more produce requests than necesary

[ https://issues.apache.org/jira/browse/KAFKA-959?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-959: Attachment: KAFKA-959.v1.patch Passed unit tests DefaultEventHandler can send

[jira] [Updated] (KAFKA-984) Avoid a full rebalance in cases when a new topic is discovered but container/broker set stay the same

[ https://issues.apache.org/jira/browse/KAFKA-984?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-984: Attachment: KAFKA-984.v2.patch Following Swapnil's comments, collapsing rebalance and

[jira] [Updated] (KAFKA-955) After a leader change, messages sent with ack=0 are lost

[ https://issues.apache.org/jira/browse/KAFKA-955?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-955: Assignee: Guozhang Wang After a leader change, messages sent with ack=0 are lost

[jira] [Updated] (KAFKA-955) After a leader change, messages sent with ack=0 are lost

[ https://issues.apache.org/jira/browse/KAFKA-955?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-955: Attachment: KAFKA-955.v1.patch After a leader change, messages sent with ack=0 are lost

[jira] [Updated] (KAFKA-955) After a leader change, messages sent with ack=0 are lost

[ https://issues.apache.org/jira/browse/KAFKA-955?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-955: Status: Patch Available (was: Open) Following the close-socket approach, I propose the following

[jira] [Updated] (KAFKA-955) After a leader change, messages sent with ack=0 are lost

[ https://issues.apache.org/jira/browse/KAFKA-955?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-955: Attachment: KAFKA-955.v1.patch Add one case for ack=0 in testSendWithDeadBroker, passed.

[jira] [Commented] (KAFKA-982) Logo for Kafka

[ https://issues.apache.org/jira/browse/KAFKA-982?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13721214#comment-13721214 ] Guozhang Wang commented on KAFKA-982: - Between 296 and 298, I will choose 296 then :)

[jira] [Reopened] (KAFKA-649) Cleanup log4j logging

[ https://issues.apache.org/jira/browse/KAFKA-649?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang reopened KAFKA-649: - Reopened for some more cleaning Cleanup log4j logging -

[jira] [Updated] (KAFKA-649) Cleanup log4j logging

[ https://issues.apache.org/jira/browse/KAFKA-649?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-649: Attachment: KAFKA-649.v3.patch Cleanup log4j logging -

[jira] [Updated] (KAFKA-649) Cleanup log4j logging

[ https://issues.apache.org/jira/browse/KAFKA-649?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-649: Status: Patch Available (was: Reopened) Guidelines of cleaning: 1. Only errors causing the server

[jira] [Created] (KAFKA-992) Double Check on Broker Registration to Avoid False NodeExist Exception

Guozhang Wang created KAFKA-992: --- Summary: Double Check on Broker Registration to Avoid False NodeExist Exception Key: KAFKA-992 URL: https://issues.apache.org/jira/browse/KAFKA-992 Project: Kafka

[jira] [Commented] (KAFKA-992) Double Check on Broker Registration to Avoid False NodeExist Exception

[ https://issues.apache.org/jira/browse/KAFKA-992?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13724789#comment-13724789 ] Guozhang Wang commented on KAFKA-992: - We can differentiate this edge case from a

[jira] [Updated] (KAFKA-992) Double Check on Broker Registration to Avoid False NodeExist Exception

[ https://issues.apache.org/jira/browse/KAFKA-992?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-992: Status: Patch Available (was: Open) In ZkUtils.registerBrokerInZk: 1. Add the current timestamp

[jira] [Commented] (KAFKA-955) After a leader change, messages sent with ack=0 are lost

[ https://issues.apache.org/jira/browse/KAFKA-955?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13725452#comment-13725452 ] Guozhang Wang commented on KAFKA-955: - Thanks for the comments Jun. 1,2,3. Done.

[jira] [Updated] (KAFKA-649) Cleanup log4j logging

[ https://issues.apache.org/jira/browse/KAFKA-649?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-649: Attachment: KAFKA-649.v5.patch One left-bracket mistyping fix. Cleanup log4j

[jira] [Updated] (KAFKA-992) Double Check on Broker Registration to Avoid False NodeExist Exception

[ https://issues.apache.org/jira/browse/KAFKA-992?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-992: Attachment: KAFKA-992.v1.patch Double Check on Broker Registration to Avoid False NodeExist

[jira] [Updated] (KAFKA-996) Capitalize first letter for log entries

[ https://issues.apache.org/jira/browse/KAFKA-996?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-996: Attachment: KAFKA-996.v1.patch Need to be rebased once 0.8 fixes are merged to trunk.

[jira] [Updated] (KAFKA-996) Capitalize first letter for log entries

[ https://issues.apache.org/jira/browse/KAFKA-996?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-996: Status: Patch Available (was: Open) Capitalize first letter for log entries

[jira] [Commented] (KAFKA-967) Use key range in ProducerPerformance

[ https://issues.apache.org/jira/browse/KAFKA-967?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13726576#comment-13726576 ] Guozhang Wang commented on KAFKA-967: - Jun, before this patch each message will use a

[jira] [Updated] (KAFKA-992) Double Check on Broker Registration to Avoid False NodeExist Exception

[ https://issues.apache.org/jira/browse/KAFKA-992?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-992: Attachment: KAFKA-992.v2.patch Unit tests passed Double Check on Broker

[jira] [Commented] (KAFKA-955) After a leader change, messages sent with ack=0 are lost

[ https://issues.apache.org/jira/browse/KAFKA-955?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13727910#comment-13727910 ] Guozhang Wang commented on KAFKA-955: - Sorry for the name misleading, I did not shut

[jira] [Updated] (KAFKA-992) Double Check on Broker Registration to Avoid False NodeExist Exception

[ https://issues.apache.org/jira/browse/KAFKA-992?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-992: Attachment: KAFKA-992.v3.patch Thanks for the comments Neha. 1,2,5: Done 3. 3.1 and 3.2/3 are

[jira] [Commented] (KAFKA-996) Capitalize first letter for log entries

[ https://issues.apache.org/jira/browse/KAFKA-996?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13729561#comment-13729561 ] Guozhang Wang commented on KAFKA-996: - Yes this patch is for trunk. As I said when 0.8

[jira] [Updated] (KAFKA-967) Use key range in ProducerPerformance

[ https://issues.apache.org/jira/browse/KAFKA-967?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-967: Attachment: KAFKA-967.v3.patch Now if messageKeyRangeOpt is not specified, null will be passed as

[jira] [Commented] (KAFKA-998) Producer should not retry on non-recoverable error codes

[ https://issues.apache.org/jira/browse/KAFKA-998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13729681#comment-13729681 ] Guozhang Wang commented on KAFKA-998: - Approach proposal: 1. Passing the errorCode

[jira] [Updated] (KAFKA-998) Producer should not retry on non-recoverable error codes

[ https://issues.apache.org/jira/browse/KAFKA-998?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-998: Status: Patch Available (was: Open) Needs rebase once 0.8 is merged in trunk.

[jira] [Updated] (KAFKA-998) Producer should not retry on non-recoverable error codes

[ https://issues.apache.org/jira/browse/KAFKA-998?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-998: Attachment: KAFKA-998.v1.patch 1. Add a function in ErrorMapping, which takes an error code and

[jira] [Commented] (KAFKA-992) Double Check on Broker Registration to Avoid False NodeExist Exception

[ https://issues.apache.org/jira/browse/KAFKA-992?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13731353#comment-13731353 ] Guozhang Wang commented on KAFKA-992: - The zookeeper bug can be reproduced as follows:

[jira] [Comment Edited] (KAFKA-992) Double Check on Broker Registration to Avoid False NodeExist Exception

[ https://issues.apache.org/jira/browse/KAFKA-992?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13731353#comment-13731353 ] Guozhang Wang edited comment on KAFKA-992 at 8/6/13 10:26 PM: --

[jira] [Updated] (KAFKA-992) Double Check on Broker Registration to Avoid False NodeExist Exception

[ https://issues.apache.org/jira/browse/KAFKA-992?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-992: Attachment: KAFKA-992.v5.patch Double Check on Broker Registration to Avoid False NodeExist

[jira] [Created] (KAFKA-1004) Handle topic event for trivial whitelist topic filters

Guozhang Wang created KAFKA-1004: Summary: Handle topic event for trivial whitelist topic filters Key: KAFKA-1004 URL: https://issues.apache.org/jira/browse/KAFKA-1004 Project: Kafka Issue

[jira] [Updated] (KAFKA-992) Double Check on Broker Registration to Avoid False NodeExist Exception

[ https://issues.apache.org/jira/browse/KAFKA-992?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-992: Attachment: KAFKA-992.v7.patch Thanks for the comment Neha. 9.1: Done. 9.2,3 Done. 10.1,2,3:

[jira] [Commented] (KAFKA-992) Double Check on Broker Registration to Avoid False NodeExist Exception

[ https://issues.apache.org/jira/browse/KAFKA-992?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13734994#comment-13734994 ] Guozhang Wang commented on KAFKA-992: - Thanks for the comments Jun. I think the

[jira] [Updated] (KAFKA-992) Double Check on Broker Registration to Avoid False NodeExist Exception

[ https://issues.apache.org/jira/browse/KAFKA-992?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-992: Attachment: KAFKA-992.v8.patch Incremental patch uploaded. Fixed a small issue that Json.parse will

[jira] [Commented] (KAFKA-990) Fix ReassignPartitionCommand and improve usability

[ https://issues.apache.org/jira/browse/KAFKA-990?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13737017#comment-13737017 ] Guozhang Wang commented on KAFKA-990: - Looks good to me overall. One question though:

[jira] [Updated] (KAFKA-992) Double Check on Broker Registration to Avoid False NodeExist Exception

[ https://issues.apache.org/jira/browse/KAFKA-992?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-992: Attachment: KAFKA-992.v9.patch Thanks for the comments. 80. Added

[jira] [Commented] (KAFKA-1008) Unmap before resizing

[ https://issues.apache.org/jira/browse/KAFKA-1008?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13737841#comment-13737841 ] Guozhang Wang commented on KAFKA-1008: -- Will this patch restrict to Sun JVM-only

[jira] [Updated] (KAFKA-992) Double Check on Broker Registration to Avoid False NodeExist Exception

[ https://issues.apache.org/jira/browse/KAFKA-992?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-992: Attachment: KAFKA-992.v10.patch Add the Controller.scala file to kafka.cluster

[jira] [Updated] (KAFKA-992) Double Check on Broker Registration to Avoid False NodeExist Exception

[ https://issues.apache.org/jira/browse/KAFKA-992?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-992: Attachment: KAFKA-992.v11.patch Forgot to pull before rebase, the new version apply to latest 0.8

[jira] [Updated] (KAFKA-1009) DumpLogSegments tool should return error on non-existing files

[ https://issues.apache.org/jira/browse/KAFKA-1009?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-1009: - Assignee: Guozhang Wang DumpLogSegments tool should return error on non-existing files

[jira] [Commented] (KAFKA-1009) DumpLogSegments tool should return error on non-existing files

[ https://issues.apache.org/jira/browse/KAFKA-1009?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13740470#comment-13740470 ] Guozhang Wang commented on KAFKA-1009: -- This is due to the fact that in dumpLog, it

[jira] [Updated] (KAFKA-1009) DumpLogSegments tool should return error on non-existing files

[ https://issues.apache.org/jira/browse/KAFKA-1009?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-1009: - Attachment: KAFKA-1009.v1.patch DumpLogSegments tool should return error on non-existing

[jira] [Updated] (KAFKA-1009) DumpLogSegments tool should return error on non-existing files

[ https://issues.apache.org/jira/browse/KAFKA-1009?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-1009: - Status: Patch Available (was: Open) DumpLogSegments tool should return error on

[jira] [Updated] (KAFKA-1007) Document new tools before 0.8 release

[ https://issues.apache.org/jira/browse/KAFKA-1007?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-1007: - Assignee: Guozhang Wang Document new tools before 0.8 release

[jira] [Updated] (KAFKA-1004) Handle topic event for trivial whitelist topic filters

[ https://issues.apache.org/jira/browse/KAFKA-1004?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-1004: - Attachment: KAFKA-1004.v1.patch Handle topic event for trivial whitelist topic filters

[jira] [Updated] (KAFKA-1004) Handle topic event for trivial whitelist topic filters

[ https://issues.apache.org/jira/browse/KAFKA-1004?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-1004: - Status: Patch Available (was: Open) Handle topic event for trivial whitelist topic filters

[jira] [Commented] (KAFKA-1010) Concurrency issue in getCluster() causes rebalance failure and dead consumer

[ https://issues.apache.org/jira/browse/KAFKA-1010?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13741148#comment-13741148 ] Guozhang Wang commented on KAFKA-1010: -- This looks good to me. If the broker

[jira] [Commented] (KAFKA-527) Compression support does numerous byte copies

[ https://issues.apache.org/jira/browse/KAFKA-527?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13741294#comment-13741294 ] Guozhang Wang commented on KAFKA-527: - One alternative approach would be like this:

[jira] [Created] (KAFKA-1011) Decompression and re-compression on MirrorMaker could result in messages being dropped in the pipeline

Guozhang Wang created KAFKA-1011: Summary: Decompression and re-compression on MirrorMaker could result in messages being dropped in the pipeline Key: KAFKA-1011 URL:

[jira] [Commented] (KAFKA-992) Double Check on Broker Registration to Avoid False NodeExist Exception

[ https://issues.apache.org/jira/browse/KAFKA-992?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13741587#comment-13741587 ] Guozhang Wang commented on KAFKA-992: - Thanks for the comments, Neha, Jun. And sorry

[jira] [Updated] (KAFKA-992) Double Check on Broker Registration to Avoid False NodeExist Exception

[ https://issues.apache.org/jira/browse/KAFKA-992?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-992: Attachment: KAFKA-992.v12.patch Double Check on Broker Registration to Avoid False NodeExist

[jira] [Commented] (KAFKA-992) Double Check on Broker Registration to Avoid False NodeExist Exception

[ https://issues.apache.org/jira/browse/KAFKA-992?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13742296#comment-13742296 ] Guozhang Wang commented on KAFKA-992: - As few more thoughts about 113: currently

[jira] [Updated] (KAFKA-992) Double Check on Broker Registration to Avoid False NodeExist Exception

[ https://issues.apache.org/jira/browse/KAFKA-992?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-992: Attachment: KAFKA-992.v13.patch Double Check on Broker Registration to Avoid False NodeExist

[jira] [Commented] (KAFKA-992) Double Check on Broker Registration to Avoid False NodeExist Exception

[ https://issues.apache.org/jira/browse/KAFKA-992?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13742356#comment-13742356 ] Guozhang Wang commented on KAFKA-992: - Thanks for the comments Jun. 114. Agreed,

[jira] [Updated] (KAFKA-1004) Handle topic event for trivial whitelist topic filters

[ https://issues.apache.org/jira/browse/KAFKA-1004?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-1004: - Attachment: KAFKA-1004.v2.patch Handle topic event for trivial whitelist topic filters

[jira] [Commented] (KAFKA-1004) Handle topic event for trivial whitelist topic filters

[ https://issues.apache.org/jira/browse/KAFKA-1004?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13742369#comment-13742369 ] Guozhang Wang commented on KAFKA-1004: -- Good point. v2 applied. Also removed part of

[jira] [Updated] (KAFKA-992) Double Check on Broker Registration to Avoid False NodeExist Exception

[ https://issues.apache.org/jira/browse/KAFKA-992?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-992: Attachment: KAFKA-992.v14.patch Thanks for the comments, added to resign, rebased on 0.8.

[jira] [Commented] (KAFKA-1007) Document new tools before 0.8 release

[ https://issues.apache.org/jira/browse/KAFKA-1007?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13743014#comment-13743014 ] Guozhang Wang commented on KAFKA-1007: -- Have added the AddPartitionCommand Tool

[jira] [Updated] (KAFKA-1009) DumpLogSegments tool should return error on non-existing files

[ https://issues.apache.org/jira/browse/KAFKA-1009?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-1009: - Attachment: KAFKA-1009.v2.patch Thanks for the comments Neha. 1. We do set default mutable to

[jira] [Commented] (KAFKA-990) Fix ReassignPartitionCommand and improve usability

[ https://issues.apache.org/jira/browse/KAFKA-990?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13743970#comment-13743970 ] Guozhang Wang commented on KAFKA-990: - Just one more comment: as for Swapnil's 16,

[jira] [Commented] (KAFKA-955) After a leader change, messages sent with ack=0 are lost

[ https://issues.apache.org/jira/browse/KAFKA-955?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13746791#comment-13746791 ] Guozhang Wang commented on KAFKA-955: - Hello Magnus, 1. Under Ack=0, the producer does

[jira] [Updated] (KAFKA-1011) Decompression and re-compression on MirrorMaker could result in messages being dropped in the pipeline

[ https://issues.apache.org/jira/browse/KAFKA-1011?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-1011: - Assignee: Guozhang Wang Decompression and re-compression on MirrorMaker could result in

[jira] [Commented] (KAFKA-1011) Decompression and re-compression on MirrorMaker could result in messages being dropped in the pipeline

[ https://issues.apache.org/jira/browse/KAFKA-1011?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13747631#comment-13747631 ] Guozhang Wang commented on KAFKA-1011: -- Proposed Approach: 1. Since the compression

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

Guozhang Wang created KAFKA-1019: Summary: kafka-preferred-replica-election.sh will fail without clear error message if /brokers/topics/[topic]/partitions does not exist Key: KAFKA-1019 URL:

[jira] [Commented] (KAFKA-1017) High number of open file handles in 0.8 producer

[ https://issues.apache.org/jira/browse/KAFKA-1017?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13747663#comment-13747663 ] Guozhang Wang commented on KAFKA-1017: -- Good catch, thanks Swapnil!

  1   2   3   4   5   6   7   8   9   10   >