[
https://issues.apache.org/jira/browse/KAFKA-999?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13730439#comment-13730439
]
Swapnil Ghike commented on KAFKA-999:
-
Since we need leader broker's host:port to creat
[
https://issues.apache.org/jira/browse/KAFKA-1002?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Swapnil Ghike updated KAFKA-1002:
-
Description: After KAFKA-999 is committed, we don't need aliveLeaders in
LeaderAndIsrRequest. (w
[
https://issues.apache.org/jira/browse/KAFKA-999?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13730348#comment-13730348
]
Swapnil Ghike commented on KAFKA-999:
-
Perhaps the word live misled me. Thanks for the
Swapnil Ghike created KAFKA-1002:
Summary: Delete aliveLeaders field from LeaderAndIsrRequest
Key: KAFKA-1002
URL: https://issues.apache.org/jira/browse/KAFKA-1002
Project: Kafka
Issue Type:
[
https://issues.apache.org/jira/browse/KAFKA-999?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13730340#comment-13730340
]
Neha Narkhede commented on KAFKA-999:
-
>> However controller passing live brokers minus
[
https://issues.apache.org/jira/browse/KAFKA-615?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jay Kreps resolved KAFKA-615.
-
Resolution: Fixed
Fix Version/s: 0.8.1
Assignee: Jay Kreps (was: Neha Narkhede)
Ah, nice
[
https://issues.apache.org/jira/browse/KAFKA-999?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13730331#comment-13730331
]
Swapnil Ghike commented on KAFKA-999:
-
I see your points. After thinking a bit about th
[
https://issues.apache.org/jira/browse/KAFKA-615?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13730325#comment-13730325
]
Jun Rao commented on KAFKA-615:
---
Thanks for patch v8. Just the following comment. Otherwise,
[
https://issues.apache.org/jira/browse/KAFKA-717?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13730320#comment-13730320
]
Rob Withers commented on KAFKA-717:
---
patch tarball no longer applies cleanly to 0.8
Robs
[
https://issues.apache.org/jira/browse/KAFKA-999?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13730294#comment-13730294
]
Neha Narkhede edited comment on KAFKA-999 at 8/6/13 3:03 AM:
-
S
[
https://issues.apache.org/jira/browse/KAFKA-999?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13730294#comment-13730294
]
Neha Narkhede commented on KAFKA-999:
-
Sriram, Ack you are right. Forgot to mention tha
[
https://issues.apache.org/jira/browse/KAFKA-989?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jun Rao updated KAFKA-989:
--
Resolution: Fixed
Fix Version/s: 0.8
Assignee: Phil Hargett
Status: Resolved (was: Pa
[
https://issues.apache.org/jira/browse/KAFKA-999?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13730243#comment-13730243
]
Swapnil Ghike commented on KAFKA-999:
-
I think the right fix would be to undo any chang
[
https://issues.apache.org/jira/browse/KAFKA-615?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13730154#comment-13730154
]
Jay Kreps commented on KAFKA-615:
-
Filed KAFKA-1001 to handle the follow-up work to optimiz
[
https://issues.apache.org/jira/browse/KAFKA-615?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13730155#comment-13730155
]
Jay Kreps commented on KAFKA-615:
-
Also, Jun, basic system tests all pass with v8.
Jay Kreps created KAFKA-1001:
Summary: Handle follower transition in batch
Key: KAFKA-1001
URL: https://issues.apache.org/jira/browse/KAFKA-1001
Project: Kafka
Issue Type: Improvement
[
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 deci
[
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.
> Pr
[
https://issues.apache.org/jira/browse/KAFKA-615?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13729989#comment-13729989
]
Sriram Subramanian commented on KAFKA-615:
--
+1
> Avoid fsync on l
[
https://issues.apache.org/jira/browse/KAFKA-615?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jay Kreps updated KAFKA-615:
Attachment: KAFKA-615-v8.patch
Ack, yes, I did mean to fix the recoveryPoint/logEndOffset issue, I just
for
[
https://issues.apache.org/jira/browse/KAFKA-615?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13729935#comment-13729935
]
Sriram Subramanian commented on KAFKA-615:
--
Do you not want to reset the recoveryP
[
https://issues.apache.org/jira/browse/KAFKA-615?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jay Kreps updated KAFKA-615:
Attachment: KAFKA-615-v7.patch
Patch which uses the correct but slow approach of synchronously committing th
[
https://issues.apache.org/jira/browse/KAFKA-999?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13729869#comment-13729869
]
Sriram Subramanian commented on KAFKA-999:
--
+1 on the proposed fix. Also this coul
[
https://issues.apache.org/jira/browse/KAFKA-999?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13729864#comment-13729864
]
Neha Narkhede commented on KAFKA-999:
-
I think the fix is to remove the smart in the br
[
https://issues.apache.org/jira/browse/KAFKA-989?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13729842#comment-13729842
]
Phil Hargett commented on KAFKA-989:
I also think I've convinced myself that while the
[
https://issues.apache.org/jira/browse/KAFKA-615?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13729835#comment-13729835
]
Jay Kreps commented on KAFKA-615:
-
Okay it looks like the fetch requests are only stopped i
[
https://issues.apache.org/jira/browse/KAFKA-989?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Phil Hargett updated KAFKA-989:
---
Attachment: KAFKA-989-failed-to-find-leader-patch3.patch
Changed to reuse the existing rebalanceLock i
Issue Subscription
Filter: outstanding kafka patches (66 issues)
The list of outstanding kafka patches
Subscriber: kafka-mailing-list
Key Summary
KAFKA-997 Provide a strict verification mode when reading configuration
properties
https://issues.apache.org/jira/browse/
[
https://issues.apache.org/jira/browse/KAFKA-615?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13729700#comment-13729700
]
Jay Kreps commented on KAFKA-615:
-
Jun.
52.2 In most filesystems there is no guarantee tha
[
https://issues.apache.org/jira/browse/KAFKA-989?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13729682#comment-13729682
]
Phil Hargett commented on KAFKA-989:
Yes, but my working hypothesis is that because the
[
https://issues.apache.org/jira/browse/KAFKA-615?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13729684#comment-13729684
]
Jay Kreps commented on KAFKA-615:
-
1.1 Good catch
2.1 My desire is to ensure that checkpoin
[
https://issues.apache.org/jira/browse/KAFKA-998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13729681#comment-13729681
]
Guozhang Wang commented on KAFKA-998:
-
Approach proposal:
1. Passing the errorCode fro
[
https://issues.apache.org/jira/browse/KAFKA-718?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jay Kreps updated KAFKA-718:
Resolution: Fixed
Fix Version/s: 0.8
Assignee: Jay Kreps (was: Neha Narkhede)
Sta
[
https://issues.apache.org/jira/browse/KAFKA-989?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13729666#comment-13729666
]
Jun Rao commented on KAFKA-989:
---
Hmm, in the shutdown logic of consumer connector, we set zkc
[
https://issues.apache.org/jira/browse/KAFKA-992?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13729652#comment-13729652
]
Neha Narkhede commented on KAFKA-992:
-
+1 on v4
> Double Check on Brok
[
https://issues.apache.org/jira/browse/KAFKA-992?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Neha Narkhede updated KAFKA-992:
Resolution: Fixed
Status: Resolved (was: Patch Available)
Committed to 0.8
[
https://issues.apache.org/jira/browse/KAFKA-615?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13729651#comment-13729651
]
Sriram Subramanian commented on KAFKA-615:
--
1. Log.scala
1.1 Doc fix. I see two of
[
https://issues.apache.org/jira/browse/KAFKA-989?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13729635#comment-13729635
]
Phil Hargett commented on KAFKA-989:
Thanks for the feedback! Working on a patch that i
[
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 th
[
https://issues.apache.org/jira/browse/KAFKA-989?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13729625#comment-13729625
]
Jun Rao commented on KAFKA-989:
---
Thanks for the patch. I think it addresses one particular is
[
https://issues.apache.org/jira/browse/KAFKA-992?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13729607#comment-13729607
]
Swapnil Ghike commented on KAFKA-992:
-
+1
> Double Check on Broker Reg
Tejas Patil created KAFKA-1000:
--
Summary: Inbuilt consumer offset management
Key: KAFKA-1000
URL: https://issues.apache.org/jira/browse/KAFKA-1000
Project: Kafka
Issue Type: New Feature
[
https://issues.apache.org/jira/browse/KAFKA-998?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang updated KAFKA-998:
Assignee: Guozhang Wang
> Producer should not retry on non-recoverable error codes
> ---
[
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.v4.patch
Thanks for the comments Neha.
6,7: Done.
Going to deploy for scenar
[
https://issues.apache.org/jira/browse/KAFKA-992?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13729569#comment-13729569
]
Jun Rao commented on KAFKA-992:
---
It seems that it's going to take some time before this issue
[
https://issues.apache.org/jira/browse/KAFKA-718?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13729565#comment-13729565
]
Jun Rao commented on KAFKA-718:
---
+1 on v5.
> kafka-run-class.sh should use r
[
https://issues.apache.org/jira/browse/KAFKA-615?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13729559#comment-13729559
]
Jun Rao commented on KAFKA-615:
---
50.3 Yes, I think your reasoning is correct. I didn't look a
[
https://issues.apache.org/jira/browse/KAFKA-996?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13729561#comment-13729561
]
Guozhang Wang commented on KAFKA-996:
-
Yes this patch is for trunk. As I said when 0.8
[
https://issues.apache.org/jira/browse/KAFKA-989?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Phil Hargett updated KAFKA-989:
---
Attachment: KAFKA-989-failed-to-find-leader-patch2.patch
> Race condition shutting down high-level
[
https://issues.apache.org/jira/browse/KAFKA-989?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Phil Hargett updated KAFKA-989:
---
Status: Patch Available (was: Open)
When in doubt about how to fix a locking issue...add another lock
50 matches
Mail list logo