Chris,
I plan to submit an infra ticket for the post graduation items. One of the
subtasks will be to move our svn repo to a new location (w/o incubator). We
could either reuse your ticket and ask for a new repo name or we could
close your ticket and create a new one. Which one would you prefer?
[
https://issues.apache.org/jira/browse/KAFKA-635?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13505222#comment-13505222
]
Jun Rao commented on KAFKA-635:
---
Chris,
Thanks for reporting this. Do you really nee
Jun Rao created KAFKA-633:
-
Summary: AdminTest.testShutdownBroker fails
Key: KAFKA-633
URL: https://issues.apache.org/jira/browse/KAFKA-633
Project: Kafka
Issue Type: Bug
Components: core
Jun Rao created KAFKA-632:
-
Summary: ProducerRequest should take ByteBufferMessageSet instead
of MessageSet
Key: KAFKA-632
URL: https://issues.apache.org/jira/browse/KAFKA-632
Project: Kafka
Issue
Hi,
Since we are getting close to the 0.8 release, I have made the following
svn changes in our repository.
moved 0.7 branch to 0.7.0
moved trunk to 0.7
copied 0.8 to trunk
Now trunk is available for post 0.8 development. 0.8 changes will still be
checked into the 0.8 branch and we will merge th
Hi, Everyone,
Thanks to people who contributed to the project, we have made significant
progress in Kafka replication. Now, we'd like people to give it a try.
Please check out revision 1411070 from
https://svn.apache.org/repos/asf/incubator/kafka/branches/0.8 and follow
the following wiki.
https:
[
https://issues.apache.org/jira/browse/KAFKA-612?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jun Rao closed KAFKA-612.
-
> 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:
--
Resolution: Fixed
Fix Version/s: 0.8
Status: Resolved (was: Patch Available)
Thanks for the
[
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-v2.patch
Thanks for the review. Attach patch v2.
1.1 This is to handle the case that a
[
https://issues.apache.org/jira/browse/KAFKA-532?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13499941#comment-13499941
]
Jun Rao commented on KAFKA-532:
---
50. My feeling is that request level error code conveys
[
https://issues.apache.org/jira/browse/KAFKA-532?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13499860#comment-13499860
]
Jun Rao commented on KAFKA-532:
---
Thanks for patch v5. Looks good. Just a couple of m
[
https://issues.apache.org/jira/browse/KAFKA-613?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jun Rao resolved KAFKA-613.
---
Resolution: Fixed
Fix Version/s: 0.8
Thanks for patch v2. +1. Committed to 0.8
[
https://issues.apache.org/jira/browse/KAFKA-613?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jun Rao closed KAFKA-613.
-
> MigrationTool should disable shallow iteration in the 0.7 consu
[
https://issues.apache.org/jira/browse/KAFKA-618?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13499309#comment-13499309
]
Jun Rao commented on KAFKA-618:
---
Thanks for the patch. +1
> D
[
https://issues.apache.org/jira/browse/KAFKA-614?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jun Rao resolved KAFKA-614.
---
Resolution: Fixed
Fix Version/s: 0.8
Thanks for the patch. +1 and committed to 0.8
[
https://issues.apache.org/jira/browse/KAFKA-614?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jun Rao closed KAFKA-614.
-
> DumpLogSegment offset verification is incorrect for compressed messa
[
https://issues.apache.org/jira/browse/KAFKA-613?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13499269#comment-13499269
]
Jun Rao commented on KAFKA-613:
---
Thanks for patch v1. It would be good to also log a war
[
https://issues.apache.org/jira/browse/KAFKA-620?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13499043#comment-13499043
]
Jun Rao commented on KAFKA-620:
---
Do you have other ZK hosts in your connection st
[
https://issues.apache.org/jira/browse/KAFKA-605?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jun Rao updated KAFKA-605:
--
Resolution: Fixed
Fix Version/s: 0.8
Status: Resolved (was: Patch Available)
Thanks for the
[
https://issues.apache.org/jira/browse/KAFKA-605?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jun Rao closed KAFKA-605.
-
> System Test - Log Retention Cases should wait longer before getting the
> common starting offset in r
[
https://issues.apache.org/jira/browse/KAFKA-618?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13498555#comment-13498555
]
Jun Rao commented on KAFKA-618:
---
This is a very good finding. The following is one wa
Jun Rao created KAFKA-614:
-
Summary: DumpLogSegment offset verification is incorrect for
compressed messages
Key: KAFKA-614
URL: https://issues.apache.org/jira/browse/KAFKA-614
Project: Kafka
Issue
Jun Rao created KAFKA-613:
-
Summary: MigrationTool should disable shallow iteration in the 0.7
consumer
Key: KAFKA-613
URL: https://issues.apache.org/jira/browse/KAFKA-613
Project: Kafka
Issue Type
[
https://issues.apache.org/jira/browse/KAFKA-544?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13497755#comment-13497755
]
Jun Rao commented on KAFKA-544:
---
+1 on patch v5. For 30, could you add the same constru
[
https://issues.apache.org/jira/browse/KAFKA-544?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13497680#comment-13497680
]
Jun Rao commented on KAFKA-544:
---
Thanks for patch v3. Looks good overall. Some m
[
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
[
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
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-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
[
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-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-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
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-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
[
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: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=13491642#comment-13491642
]
Jun Rao commented on KAFKA-574:
---
Thanks for patch v3. Just one more comment:
[
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-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-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-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-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=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-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
I think that's a good idea. It will be good to have at least 2 maintainers
per component.
I'd encourage more people to review patches. The more patches one reviews,
the more familiar he/she is with the components.
Thanks,
Jun
On Thu, Oct 4, 2012 at 1:13 PM, Jay Kreps wrote:
> Hey guys,
>
> Th
[
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-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-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-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-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-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-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-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:
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-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-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-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
[
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-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-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=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=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-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-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-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-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-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-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-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: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-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-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-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-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-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
we move to git ?
>
> On Fri, Oct 26, 2012 at 7:41 PM, Jun Rao wrote:
>
> > The 0.8 branch has stabilized quite a bit now. We still have to look into
> > some corner cases and performance, but most system tests are now
> passing. I
> > think it's time to bring 0.
[
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-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-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=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-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-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-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-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:
--
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-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-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-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-571?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jun Rao closed KAFKA-571.
-
> Add more test cases to System Test
> --
>
> Ke
1 - 100 of 1410 matches
Mail list logo