[
https://issues.apache.org/jira/browse/KAFKA-267?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13480112#comment-13480112
]
Jun Rao commented on KAFKA-267:
---
Thanks for patch v4. It's better, but still me
[
https://issues.apache.org/jira/browse/KAFKA-571?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jun Rao updated KAFKA-571:
--
Attachment: kafka-571-SimpleConsumerShell.patch
Thanks for the patch. Some comments:
1. I patched
Jun Rao created KAFKA-579:
-
Summary: remove connection timeout in SyncProducer
Key: KAFKA-579
URL: https://issues.apache.org/jira/browse/KAFKA-579
Project: Kafka
Issue Type: Bug
Components
[
https://issues.apache.org/jira/browse/KAFKA-574?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13481068#comment-13481068
]
Jun Rao commented on KAFKA-574:
---
Sure, Prashanth. Do you think that you can provide a p
[
https://issues.apache.org/jira/browse/KAFKA-77?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13481140#comment-13481140
]
Jun Rao commented on KAFKA-77:
--
I think what Jay meant is that in 0.8, a message is consid
Jun Rao created KAFKA-580:
-
Summary: system test testcase_0122 under replication fails due to
large # of data loss
Key: KAFKA-580
URL: https://issues.apache.org/jira/browse/KAFKA-580
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-580?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jun Rao updated KAFKA-580:
--
Attachment: kafka-580.patch
Attach a patch. The problem is that if we remove items from a set while
iterating
[
https://issues.apache.org/jira/browse/KAFKA-580?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jun Rao updated KAFKA-580:
--
Status: Patch Available (was: Open)
> system test testcase_0122 under replication fails due to large #
[
https://issues.apache.org/jira/browse/KAFKA-580?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jun Rao reassigned KAFKA-580:
-
Assignee: Jun Rao
> system test testcase_0122 under replication fails due to large # of data l
[
https://issues.apache.org/jira/browse/KAFKA-571?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13482481#comment-13482481
]
Jun Rao commented on KAFKA-571:
---
Thanks for patch v2. Looks good. One more comment.
20
[
https://issues.apache.org/jira/browse/KAFKA-580?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jun Rao updated KAFKA-580:
--
Resolution: Fixed
Fix Version/s: 0.8
Status: Resolved (was: Patch Available)
Thanks for the
[
https://issues.apache.org/jira/browse/KAFKA-580?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jun Rao closed KAFKA-580.
-
> system test testcase_0122 under replication fails due to large # of data l
[
https://issues.apache.org/jira/browse/KAFKA-340?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13482553#comment-13482553
]
Jun Rao commented on KAFKA-340:
---
Thanks for patch v2. Some more comments and clarifica
[
https://issues.apache.org/jira/browse/KAFKA-578?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jun Rao closed KAFKA-578.
-
> Leader finder thread in ConsumerFetcherManager needs to handle excepti
[
https://issues.apache.org/jira/browse/KAFKA-578?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jun Rao resolved KAFKA-578.
---
Resolution: Fixed
Fix Version/s: 0.8
Fixed as kafka-580.
> Leader finder thread
[
https://issues.apache.org/jira/browse/KAFKA-576?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jun Rao closed KAFKA-576.
-
> SimpleConsumer throws UnsupportedOperationException: empty.h
[
https://issues.apache.org/jira/browse/KAFKA-576?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jun Rao resolved KAFKA-576.
---
Resolution: Fixed
Fix Version/s: 0.8
Thanks for the patch. Committed to 0.8 with the following minor
[
https://issues.apache.org/jira/browse/KAFKA-267?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13483293#comment-13483293
]
Jun Rao commented on KAFKA-267:
---
Thanks for patch v5. Looks good. Some minor comments:
[
https://issues.apache.org/jira/browse/KAFKA-556?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jun Rao resolved KAFKA-556.
---
Resolution: Fixed
Fix Version/s: 0.8
+1. Committed to 0.8.
> Cha
[
https://issues.apache.org/jira/browse/KAFKA-556?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jun Rao closed KAFKA-556.
-
> Change MessageSet.sizeInBytes to Int
>
>
> Ke
[
https://issues.apache.org/jira/browse/KAFKA-491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13483367#comment-13483367
]
Jun Rao commented on KAFKA-491:
---
Thanks for patch v1. Some comments:
1. KafkaApis:
1.1
[
https://issues.apache.org/jira/browse/KAFKA-579?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jun Rao resolved KAFKA-579.
---
Resolution: Fixed
Fix Version/s: 0.8
Thanks for the patch. +1. Committed to 0.8 after removing an
[
https://issues.apache.org/jira/browse/KAFKA-579?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jun Rao closed KAFKA-579.
-
> remove connection timeout in SyncProducer
> -
>
>
[
https://issues.apache.org/jira/browse/KAFKA-581?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jun Rao resolved KAFKA-581.
---
Resolution: Fixed
Thanks for the patch. Committed to 0.8 in bin/windows/.
> provides wind
[
https://issues.apache.org/jira/browse/KAFKA-581?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jun Rao closed KAFKA-581.
-
> provides windows batch script for starting Kafka/Zookee
[
https://issues.apache.org/jira/browse/KAFKA-579?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13483399#comment-13483399
]
Jun Rao commented on KAFKA-579:
---
Very good point. To address this issue, we have cre
[
https://issues.apache.org/jira/browse/KAFKA-571?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jun Rao updated KAFKA-571:
--
Resolution: Fixed
Status: Resolved (was: Patch Available)
Thanks for the patch. +1. Committed to 0.8
[
https://issues.apache.org/jira/browse/KAFKA-571?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jun Rao closed KAFKA-571.
-
> Add more test cases to System Test
> --
>
> Ke
[
https://issues.apache.org/jira/browse/KAFKA-340?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13483657#comment-13483657
]
Jun Rao commented on KAFKA-340:
---
21.2 My confusion is that I tho
[
https://issues.apache.org/jira/browse/KAFKA-340?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13483894#comment-13483894
]
Jun Rao commented on KAFKA-340:
---
21.4 I looked again. Yes, your code is correct.
One
[
https://issues.apache.org/jira/browse/KAFKA-581?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13484233#comment-13484233
]
Jun Rao commented on KAFKA-581:
---
Since we have quite a few scripts in bin/. I think
[
https://issues.apache.org/jira/browse/KAFKA-584?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jun Rao updated KAFKA-584:
--
Attachment: kafka-584.patch
Attach a patch. The problem is that with ack = 1, response could be sent before
[
https://issues.apache.org/jira/browse/KAFKA-584?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13484251#comment-13484251
]
Jun Rao commented on KAFKA-584:
---
Also, volatile makes a long value atomic according to
[
https://issues.apache.org/jira/browse/KAFKA-584?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jun Rao updated KAFKA-584:
--
Fix Version/s: 0.8
Assignee: Jun Rao
Status: Patch Available (was: Open)
> prod
[
https://issues.apache.org/jira/browse/KAFKA-584?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jun Rao updated KAFKA-584:
--
Resolution: Fixed
Status: Resolved (was: Patch Available)
Thanks for the review. Changed the logging
[
https://issues.apache.org/jira/browse/KAFKA-584?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jun Rao closed KAFKA-584.
-
> produce/fetch remote time metric not set correctly when num.acks
[
https://issues.apache.org/jira/browse/KAFKA-588?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jun Rao updated KAFKA-588:
--
Labels: bugs (was: )
> Index truncation doesn't seem to remove the last entry
Jun Rao created KAFKA-588:
-
Summary: Index truncation doesn't seem to remove the last entry
properly
Key: KAFKA-588
URL: https://issues.apache.org/jira/browse/KAFKA-588
Project: Kafka
Issue
[
https://issues.apache.org/jira/browse/KAFKA-588?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13485020#comment-13485020
]
Jun Rao commented on KAFKA-588:
---
>From the log, the broker wants to truncate log to
[
https://issues.apache.org/jira/browse/KAFKA-267?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13485024#comment-13485024
]
Jun Rao commented on KAFKA-267:
---
Thanks for patch v7. Not sure if printing message
[
https://issues.apache.org/jira/browse/KAFKA-532?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13485030#comment-13485030
]
Jun Rao commented on KAFKA-532:
---
The purpose of controller epoc is to prevent an o
[
https://issues.apache.org/jira/browse/KAFKA-267?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13485042#comment-13485042
]
Jun Rao commented on KAFKA-267:
---
What we can do is that, in system tests, tune #retries
[
https://issues.apache.org/jira/browse/KAFKA-577?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13485306#comment-13485306
]
Jun Rao commented on KAFKA-577:
---
Thanks for the patch. Some comments:
1. Could you a
[
https://issues.apache.org/jira/browse/KAFKA-589?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13485798#comment-13485798
]
Jun Rao commented on KAFKA-589:
---
This problem exists in 0.8 too. What we need to do i
[
https://issues.apache.org/jira/browse/KAFKA-589?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jun Rao updated KAFKA-589:
--
Affects Version/s: 0.8
Labels: bugs newbie (was: )
> Clean shutdown after star
[
https://issues.apache.org/jira/browse/KAFKA-575?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13486079#comment-13486079
]
Jun Rao commented on KAFKA-575:
---
Patch looks good. Just one comment
[
https://issues.apache.org/jira/browse/KAFKA-574?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13486091#comment-13486091
]
Jun Rao commented on KAFKA-574:
---
Thanks for the patch. Some comments
[
https://issues.apache.org/jira/browse/KAFKA-188?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13486145#comment-13486145
]
Jun Rao commented on KAFKA-188:
---
Thanks for patch v5. Some more comments:
[
https://issues.apache.org/jira/browse/KAFKA-577?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jun Rao updated KAFKA-577:
--
Comment: was deleted
(was: +1 on patch v6. Committed to 0.8.)
> extend DumpLogSegments to ver
[
https://issues.apache.org/jira/browse/KAFKA-577?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jun Rao resolved KAFKA-577.
---
Resolution: Fixed
Fix Version/s: 0.8
+1 on patch v6. Committed to 0.8.
> ext
[
https://issues.apache.org/jira/browse/KAFKA-267?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jun Rao updated KAFKA-267:
--
Resolution: Fixed
Fix Version/s: 0.8
Status: Resolved (was: Patch Available)
+1 on patch v6
[
https://issues.apache.org/jira/browse/KAFKA-577?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13486548#comment-13486548
]
Jun Rao commented on KAFKA-577:
---
Thanks for patch v2. Instead of exiting on f
[
https://issues.apache.org/jira/browse/KAFKA-588?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13486567#comment-13486567
]
Jun Rao commented on KAFKA-588:
---
Thanks for the patch. In LogSegmentTest, could we
[
https://issues.apache.org/jira/browse/KAFKA-575?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jun Rao resolved KAFKA-575.
---
Resolution: Fixed
Fix Version/s: 0.8
Thanks for patch v3. +1. Committed to 0.8
[
https://issues.apache.org/jira/browse/KAFKA-575?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jun Rao closed KAFKA-575.
-
> Partition.makeFollower() reads broker info from
[
https://issues.apache.org/jira/browse/KAFKA-577?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jun Rao reopened KAFKA-577:
---
> extend DumpLogSegments to verify consistency btw data and in
[
https://issues.apache.org/jira/browse/KAFKA-592?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jun Rao resolved KAFKA-592.
---
Resolution: Fixed
Thanks for the patch. +1. Committed to 0.8 by making registerStats private and
adding a
[
https://issues.apache.org/jira/browse/KAFKA-592?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jun Rao closed KAFKA-592.
-
> Register metrics beans at kafka server star
[
https://issues.apache.org/jira/browse/KAFKA-188?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13486921#comment-13486921
]
Jun Rao commented on KAFKA-188:
---
Our system tests fail with the latest patch.
pytho
[
https://issues.apache.org/jira/browse/KAFKA-593?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13486990#comment-13486990
]
Jun Rao commented on KAFKA-593:
---
Producer used sync mode. So, there is 1 message per b
[
https://issues.apache.org/jira/browse/KAFKA-188?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13487307#comment-13487307
]
Jun Rao commented on KAFKA-188:
---
Now, some unit tests fail with exceptions like
[
https://issues.apache.org/jira/browse/KAFKA-593?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13487841#comment-13487841
]
Jun Rao commented on KAFKA-593:
---
Here is the issue. We rolled a new segment in the foll
[
https://issues.apache.org/jira/browse/KAFKA-594?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jun Rao closed KAFKA-594.
-
> Update System Test due to new argument "--sync" in Produc
[
https://issues.apache.org/jira/browse/KAFKA-594?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jun Rao updated KAFKA-594:
--
Resolution: Fixed
Fix Version/s: 0.8
Assignee: John Fung
Status: Resolved (was
[
https://issues.apache.org/jira/browse/KAFKA-586?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jun Rao updated KAFKA-586:
--
Resolution: Fixed
Fix Version/s: 0.8
Status: Resolved (was: Patch Available)
Thanks for the
[
https://issues.apache.org/jira/browse/KAFKA-586?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jun Rao closed KAFKA-586.
-
> system test configs are broken
> --
>
> Ke
Jun Rao created KAFKA-596:
-
Summary: LogSegment.firstAppendTime not reset after truncate to
Key: KAFKA-596
URL: https://issues.apache.org/jira/browse/KAFKA-596
Project: Kafka
Issue Type: Bug
[
https://issues.apache.org/jira/browse/KAFKA-596?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13487947#comment-13487947
]
Jun Rao commented on KAFKA-596:
---
The fix is to set LogSegment.firstAppendTime to none i
Jun Rao created KAFKA-598:
-
Summary: decouple fetch size from max message size
Key: KAFKA-598
URL: https://issues.apache.org/jira/browse/KAFKA-598
Project: Kafka
Issue Type: Bug
Components
[
https://issues.apache.org/jira/browse/KAFKA-574?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13488810#comment-13488810
]
Jun Rao commented on KAFKA-574:
---
Thanks for patch v2. Just one more comment:
[
https://issues.apache.org/jira/browse/KAFKA-532?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13488893#comment-13488893
]
Jun Rao commented on KAFKA-532:
---
Thanks for patch v3. The overall approach seems to
[
https://issues.apache.org/jira/browse/KAFKA-188?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13489184#comment-13489184
]
Jun Rao commented on KAFKA-188:
---
+1 on patch v8. Thanks,
> Support m
[
https://issues.apache.org/jira/browse/KAFKA-491?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jun Rao resolved KAFKA-491.
---
Resolution: Fixed
Thanks for patch v2. +1. Committed to 0.8.
> KafkaRequestHandler needs
[
https://issues.apache.org/jira/browse/KAFKA-491?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jun Rao closed KAFKA-491.
-
> KafkaRequestHandler needs to handle excepti
[
https://issues.apache.org/jira/browse/KAFKA-577?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13489255#comment-13489255
]
Jun Rao commented on KAFKA-577:
---
A couple of more comments for patch v4.
40. LinkedLis
[
https://issues.apache.org/jira/browse/KAFKA-593?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13489260#comment-13489260
]
Jun Rao commented on KAFKA-593:
---
Thanks for the patch. A couple of comments
[
https://issues.apache.org/jira/browse/KAFKA-596?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13489266#comment-13489266
]
Jun Rao commented on KAFKA-596:
---
Thanks for the patch. A couple of comments
[
https://issues.apache.org/jira/browse/KAFKA-596?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13489473#comment-13489473
]
Jun Rao commented on KAFKA-596:
---
I agree that setting firstAppendTime to Non
[
https://issues.apache.org/jira/browse/KAFKA-546?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13489481#comment-13489481
]
Jun Rao commented on KAFKA-546:
---
Can't see to apply the patch cleanly to 0.8.
[
https://issues.apache.org/jira/browse/KAFKA-593?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13490770#comment-13490770
]
Jun Rao commented on KAFKA-593:
---
Thanks for patch v3. Looks good. Some minor comments.
[
https://issues.apache.org/jira/browse/KAFKA-546?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13490977#comment-13490977
]
Jun Rao commented on KAFKA-546:
---
Thanks for patch v2. Some comments:
[
https://issues.apache.org/jira/browse/KAFKA-596?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jun Rao resolved KAFKA-596.
---
Resolution: Fixed
Fix Version/s: 0.8
Thanks for patch v3. +1. Committed to 0.8
[
https://issues.apache.org/jira/browse/KAFKA-596?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jun Rao closed KAFKA-596.
-
> LogSegment.firstAppendTime not reset after truncate
[
https://issues.apache.org/jira/browse/KAFKA-577?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jun Rao resolved KAFKA-577.
---
Resolution: Fixed
Thanks for patch v6. +1. Committed to 0.8 with a minor change: using ::= on a
list instead
[
https://issues.apache.org/jira/browse/KAFKA-577?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jun Rao closed KAFKA-577.
-
> extend DumpLogSegments to verify consistency btw data and in
[
https://issues.apache.org/jira/browse/KAFKA-532?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13491566#comment-13491566
]
Jun Rao commented on KAFKA-532:
---
Thanks for patch v4. A few more comments:
[
https://issues.apache.org/jira/browse/KAFKA-574?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13491642#comment-13491642
]
Jun Rao commented on KAFKA-574:
---
Thanks for patch v3. Just one more comment:
[
https://issues.apache.org/jira/browse/KAFKA-546?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13492552#comment-13492552
]
Jun Rao commented on KAFKA-546:
---
Thanks for patch v3. A couple of more comments
[
https://issues.apache.org/jira/browse/KAFKA-574?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13492975#comment-13492975
]
Jun Rao commented on KAFKA-574:
---
Thanks for patch v4. Patch looks good and system tests
[
https://issues.apache.org/jira/browse/KAFKA-546?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jun Rao resolved KAFKA-546.
---
Resolution: Fixed
Fix Version/s: 0.8
Thanks for patch v5. +1. Committed to 0.8.
>
[
https://issues.apache.org/jira/browse/KAFKA-546?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jun Rao closed KAFKA-546.
-
> Fix commit() in zk consumer for compressed messa
Jun Rao created KAFKA-604:
-
Summary: Add missing metrics in 0.8
Key: KAFKA-604
URL: https://issues.apache.org/jira/browse/KAFKA-604
Project: Kafka
Issue Type: Bug
Components: core
[
https://issues.apache.org/jira/browse/KAFKA-591?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jun Rao updated KAFKA-591:
--
Resolution: Fixed
Fix Version/s: 0.8
Status: Resolved (was: Patch Available)
Thanks for
[
https://issues.apache.org/jira/browse/KAFKA-591?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jun Rao closed KAFKA-591.
-
> Add test cases to test log size retention and m
[
https://issues.apache.org/jira/browse/KAFKA-606?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13495387#comment-13495387
]
Jun Rao commented on KAFKA-606:
---
There seems to be 2 issues. (1) Since we only do sha
[
https://issues.apache.org/jira/browse/KAFKA-585?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13495462#comment-13495462
]
Jun Rao commented on KAFKA-585:
---
Thanks for patch v1. +1. Just make sure that the b
Jun Rao created KAFKA-612:
-
Summary: move shutting down of fetcher thread out of critical path
Key: KAFKA-612
URL: https://issues.apache.org/jira/browse/KAFKA-612
Project: Kafka
Issue Type: Bug
[
https://issues.apache.org/jira/browse/KAFKA-612?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jun Rao reassigned KAFKA-612:
-
Assignee: Jun Rao
> move shutting down of fetcher thread out of critical p
[
https://issues.apache.org/jira/browse/KAFKA-612?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jun Rao updated KAFKA-612:
--
Attachment: kafka-612.patch
Attach a patch. It introduces a separate method for shutting down empty fetcher
[
https://issues.apache.org/jira/browse/KAFKA-612?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jun Rao updated KAFKA-612:
--
Status: Patch Available (was: Open)
> move shutting down of fetcher thread out of critical p
901 - 1000 of 1410 matches
Mail list logo
