[
https://issues.apache.org/jira/browse/KAFKA-804?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13602034#comment-13602034
]
Neha Narkhede commented on KAFKA-804:
-
+1
> Incorrect index in the log
Jun Rao created KAFKA-806:
-
Summary: Index may not always observe log.index.interval.bytes
Key: KAFKA-806
URL: https://issues.apache.org/jira/browse/KAFKA-806
Project: Kafka
Issue Type: Improvement
Jun Rao created KAFKA-805:
-
Summary: log.append() may fail with a compressed messageset
containing no uncompressed messages
Key: KAFKA-805
URL: https://issues.apache.org/jira/browse/KAFKA-805
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-804?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jun Rao updated KAFKA-804:
--
Status: Patch Available (was: In Progress)
Attach a patch. It always uses the nextOffset before append as the 1
[
https://issues.apache.org/jira/browse/KAFKA-804?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jun Rao updated KAFKA-804:
--
Attachment: kafka-804.patch
> Incorrect index in the log of a follower
> ---
[
https://issues.apache.org/jira/browse/KAFKA-804?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Work on KAFKA-804 started by Jun Rao.
> Incorrect index in the log of a follower
>
>
> Key: KAFKA-804
>
Jun Rao created KAFKA-804:
-
Summary: Incorrect index in the log of a follower
Key: KAFKA-804
URL: https://issues.apache.org/jira/browse/KAFKA-804
Project: Kafka
Issue Type: Bug
Components:
[
https://issues.apache.org/jira/browse/KAFKA-803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13601735#comment-13601735
]
Jun Rao commented on KAFKA-803:
---
Since in 0.8, we haven't exposed the offset in the Producer
Jun Rao created KAFKA-803:
-
Summary: Offset returned to producer is not consistent
Key: KAFKA-803
URL: https://issues.apache.org/jira/browse/KAFKA-803
Project: Kafka
Issue Type: Bug
Repor
[
https://issues.apache.org/jira/browse/KAFKA-763?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13601729#comment-13601729
]
Jun Rao commented on KAFKA-763:
---
Thanks for patch v4. Committed to 0.8.
> Ad
[
https://issues.apache.org/jira/browse/KAFKA-797?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13601691#comment-13601691
]
Dave DeMaagd commented on KAFKA-797:
KAFKA-733 is already out there for the assembly st
[
https://issues.apache.org/jira/browse/KAFKA-763?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Swapnil Ghike updated KAFKA-763:
Attachment: kafka-763-new-v4.patch
Modified ConsumerFetcherThread to use SimpleConsumer.earliestOrLa
[
https://issues.apache.org/jira/browse/KAFKA-791?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Fung updated KAFKA-791:
Attachment: kafka-791-v2.patch
> Fix validation bugs in System Test
> --
[
https://issues.apache.org/jira/browse/KAFKA-791?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13601600#comment-13601600
]
John Fung commented on KAFKA-791:
-
Attached kafka-791-v2.patch with additional changes:
ka
[
https://issues.apache.org/jira/browse/KAFKA-791?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Fung updated KAFKA-791:
Attachment: (was: kafka-791-v2.patch)
> Fix validation bugs in System Test
> ---
[
https://issues.apache.org/jira/browse/KAFKA-791?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Fung updated KAFKA-791:
Attachment: kafka-791-v2.patch
> Fix validation bugs in System Test
> --
[
https://issues.apache.org/jira/browse/KAFKA-763?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13601588#comment-13601588
]
Jun Rao commented on KAFKA-763:
---
Thanks for patch v3. Looks good. However, I overlooked one t
[
https://issues.apache.org/jira/browse/KAFKA-763?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Neha Narkhede closed 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-tabpanel&focusedCommentId=13601572#comment-13601572
]
Neha Narkhede commented on KAFKA-763:
-
Thanks for the follow up patch, Swapnil! LGTM,
[
https://issues.apache.org/jira/browse/KAFKA-763?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Swapnil Ghike updated KAFKA-763:
Attachment: kafka-763-new-v3.patch
Since patch new-v2 has been committed, this patch contains diff o
[
https://issues.apache.org/jira/browse/KAFKA-802?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13601475#comment-13601475
]
Jun Rao commented on KAFKA-802:
---
Thanks for patch v3. +1.
> Flush message in
[
https://issues.apache.org/jira/browse/KAFKA-797?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13601458#comment-13601458
]
Bob commented on KAFKA-797:
---
Phil, yep, it's the same issue. I filed a separate bug on it
https:/
[
https://issues.apache.org/jira/browse/KAFKA-797?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13601453#comment-13601453
]
Dragos Manolescu commented on KAFKA-797:
I second David's and Phil's observations,
[
https://issues.apache.org/jira/browse/KAFKA-802?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Neha Narkhede updated KAFKA-802:
Attachment: kafka-802-v3.patch
> Flush message interval is based on compressed message count
> -
[
https://issues.apache.org/jira/browse/KAFKA-802?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13601421#comment-13601421
]
Jun Rao commented on KAFKA-802:
---
Thanks for patch v2. We need a few tweaks.
20. The assignme
[
https://issues.apache.org/jira/browse/KAFKA-802?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Neha Narkhede updated KAFKA-802:
Attachment: kafka-802-v2.patch
That is a good insight, Jun. Included that fix in v2
[
https://issues.apache.org/jira/browse/KAFKA-802?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13601393#comment-13601393
]
Jun Rao edited comment on KAFKA-802 at 3/13/13 5:28 PM:
Sriram, agr
[
https://issues.apache.org/jira/browse/KAFKA-802?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13601393#comment-13601393
]
Jun Rao commented on KAFKA-802:
---
Sriram, agreed that it's better if the meaning for flush int
[
https://issues.apache.org/jira/browse/KAFKA-801?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Neha Narkhede closed KAFKA-801.
---
> Fix MessagesInPerSec mbean to count uncompressed message rate
>
[
https://issues.apache.org/jira/browse/KAFKA-763?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13601372#comment-13601372
]
Neha Narkhede commented on KAFKA-763:
-
Yes, that method should only take replicaId. Let
[
https://issues.apache.org/jira/browse/KAFKA-801?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jun Rao updated KAFKA-801:
--
Resolution: Fixed
Fix Version/s: 0.8
Status: Resolved (was: Patch Available)
Thanks for the r
[
https://issues.apache.org/jira/browse/KAFKA-763?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13601364#comment-13601364
]
Jun Rao commented on KAFKA-763:
---
For 1, I think the logic in the patch is correct, but confus
[
https://issues.apache.org/jira/browse/KAFKA-802?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13601318#comment-13601318
]
Sriram Subramanian commented on KAFKA-802:
--
Personally, having different meaning t
[
https://issues.apache.org/jira/browse/KAFKA-802?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Neha Narkhede reassigned KAFKA-802:
---
Assignee: Neha Narkhede
> Flush message interval is based on compressed message count
> --
[
https://issues.apache.org/jira/browse/KAFKA-802?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Neha Narkhede updated KAFKA-802:
Status: Patch Available (was: Open)
> Flush message interval is based on compressed message cou
[
https://issues.apache.org/jira/browse/KAFKA-802?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Neha Narkhede updated KAFKA-802:
Attachment: kafka-802.patch
Two changes -
1. Changed the maybeFlush() call from Log.append() to tak
[
https://issues.apache.org/jira/browse/KAFKA-801?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13601295#comment-13601295
]
Neha Narkhede commented on KAFKA-801:
-
Agree, I guess we can pass on that suggestion
[
https://issues.apache.org/jira/browse/KAFKA-801?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13601282#comment-13601282
]
Jun Rao commented on KAFKA-801:
---
We could do that. However, the meaning of offsetCounter is n
[
https://issues.apache.org/jira/browse/KAFKA-763?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13601278#comment-13601278
]
Neha Narkhede commented on KAFKA-763:
-
Sorry for coming late to the review. Two suggest
[
https://issues.apache.org/jira/browse/KAFKA-801?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13601252#comment-13601252
]
Neha Narkhede commented on KAFKA-801:
-
+1. Minor simplification -
Can we do the follow
[
https://issues.apache.org/jira/browse/KAFKA-797?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13601197#comment-13601197
]
Phil Hargett commented on KAFKA-797:
Same issue here. I cloned the repo and did a chec
[
https://issues.apache.org/jira/browse/KAFKA-520?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13601190#comment-13601190
]
David Arthur commented on KAFKA-520:
This has bitten me as well. Under the covers Consu
[
https://issues.apache.org/jira/browse/KAFKA-686?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13601188#comment-13601188
]
Phil Hargett commented on KAFKA-686:
While, yes, the original issue is unaddressed, the
[
https://issues.apache.org/jira/browse/KAFKA-797?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13601162#comment-13601162
]
David Arthur commented on KAFKA-797:
I have to run "./sbt update" in order for scala-li
44 matches
Mail list logo
