[
https://issues.apache.org/jira/browse/KAFKA-813?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Swapnil Ghike updated KAFKA-813:
Labels: kafka-0.8 (was: )
> Minor cleanup in Controller
> ---
>
>
[
https://issues.apache.org/jira/browse/KAFKA-813?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Swapnil Ghike updated KAFKA-813:
Attachment: kafka-813-v2.patch
Addressing comments:
[~junrao]:
1. Renamed the exception to Partiti
[
https://issues.apache.org/jira/browse/KAFKA-813?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Swapnil Ghike updated KAFKA-813:
Priority: Blocker (was: Major)
> Minor cleanup in Controller
> ---
>
>
[
https://issues.apache.org/jira/browse/KAFKA-820?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Neha Narkhede updated KAFKA-820:
Attachment: kafka-820-v1.patch
Two changes -
1. Modified topic metadata request handling to return
[
https://issues.apache.org/jira/browse/KAFKA-820?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Neha Narkhede updated KAFKA-820:
Status: Patch Available (was: In Progress)
> Topic metadata request handling fails to return al
[
https://issues.apache.org/jira/browse/KAFKA-656?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13607129#comment-13607129
]
Jonathan Creasy commented on KAFKA-656:
---
Obviously a work in progress.
https://cwiki
[
https://issues.apache.org/jira/browse/KAFKA-820?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Neha Narkhede reassigned KAFKA-820:
---
Assignee: Neha Narkhede
> Topic metadata request handling fails to return all metadata abo
[
https://issues.apache.org/jira/browse/KAFKA-820?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Work on KAFKA-820 started by Neha Narkhede.
> Topic metadata request handling fails to return all metadata about replicas
> ---
[
https://issues.apache.org/jira/browse/KAFKA-816?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13607123#comment-13607123
]
Neha Narkhede commented on KAFKA-816:
-
Sure. And the comment is not added to handleOffs
[
https://issues.apache.org/jira/browse/KAFKA-816?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13607110#comment-13607110
]
Jun Rao commented on KAFKA-816:
---
Thanks for the patch. Instead of duplicating the comments fo
Neha Narkhede created KAFKA-820:
---
Summary: Topic metadata request handling fails to return all
metadata about replicas
Key: KAFKA-820
URL: https://issues.apache.org/jira/browse/KAFKA-820
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-815?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13607054#comment-13607054
]
Jun Rao commented on KAFKA-815:
---
Thanks for the patch. +1.
> Improve SimpleC
John Fung created KAFKA-819:
---
Summary: System Test : Add validation of log segment index to
offset
Key: KAFKA-819
URL: https://issues.apache.org/jira/browse/KAFKA-819
Project: Kafka
Issue Type: Ta
[
https://issues.apache.org/jira/browse/KAFKA-812?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Neha Narkhede closed KAFKA-812.
---
> Support deep iteration in DumpLogSegments tool
> --
>
>
[
https://issues.apache.org/jira/browse/KAFKA-812?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jun Rao updated KAFKA-812:
--
Resolution: Fixed
Fix Version/s: 0.8
Status: Resolved (was: Patch Available)
Thanks for the r
[
https://issues.apache.org/jira/browse/KAFKA-816?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Neha Narkhede updated KAFKA-816:
Attachment: kafka-816.patch
Special cased NotLeaderForPartitionException and
UnknownTopicOrPartitio
[
https://issues.apache.org/jira/browse/KAFKA-816?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Neha Narkhede updated KAFKA-816:
Status: Patch Available (was: In Progress)
> Reduce noise in Kafka server logs due to NotLeader
[
https://issues.apache.org/jira/browse/KAFKA-816?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Work on KAFKA-816 started by Neha Narkhede.
> Reduce noise in Kafka server logs due to NotLeaderForPartitionException
> ---
Neha Narkhede created KAFKA-818:
---
Summary: Request failure metrics on the Kafka brokers is not
instrumented for all requests
Key: KAFKA-818
URL: https://issues.apache.org/jira/browse/KAFKA-818
Project:
[
https://issues.apache.org/jira/browse/KAFKA-817?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Neha Narkhede updated KAFKA-817:
Labels: kafka-0.8 p2 (was: )
> Implement a zookeeper path-based controlled shutdown tool
>
Joel Koshy created KAFKA-817:
Summary: Implement a zookeeper path-based controlled shutdown tool
Key: KAFKA-817
URL: https://issues.apache.org/jira/browse/KAFKA-817
Project: Kafka
Issue Type: Bug
[
https://issues.apache.org/jira/browse/KAFKA-815?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Neha Narkhede updated KAFKA-815:
Status: Patch Available (was: In Progress)
> Improve SimpleConsumerShell to take in a max messa
Neha Narkhede created KAFKA-816:
---
Summary: Reduce noise in Kafka server logs due to
NotLeaderForPartitionException
Key: KAFKA-816
URL: https://issues.apache.org/jira/browse/KAFKA-816
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-815?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Neha Narkhede updated KAFKA-815:
Attachment: kafka-815.patch
- Added a max-messages option to SimpleConsumerShell
- Improved some log
[
https://issues.apache.org/jira/browse/KAFKA-815?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Work on KAFKA-815 started by Neha Narkhede.
> Improve SimpleConsumerShell to take in a max messages config option
> ---
Neha Narkhede created KAFKA-815:
---
Summary: Improve SimpleConsumerShell to take in a max messages
config option
Key: KAFKA-815
URL: https://issues.apache.org/jira/browse/KAFKA-815
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-804?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Neha Narkhede closed KAFKA-804.
---
> Incorrect index in the log of a follower
>
>
>
[
https://issues.apache.org/jira/browse/KAFKA-811?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13606683#comment-13606683
]
Swapnil Ghike commented on KAFKA-811:
-
The 1st patch will pass client ids like abc-0, a
[
https://issues.apache.org/jira/browse/KAFKA-811?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13606680#comment-13606680
]
Neha Narkhede commented on KAFKA-811:
-
it looks like the same, what is the change ?
[
https://issues.apache.org/jira/browse/KAFKA-813?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13606678#comment-13606678
]
Neha Narkhede commented on KAFKA-813:
-
Correct, another way to do this is to defined a
[
https://issues.apache.org/jira/browse/KAFKA-813?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13606672#comment-13606672
]
Swapnil Ghike edited comment on KAFKA-813 at 3/19/13 7:06 PM:
--
[
https://issues.apache.org/jira/browse/KAFKA-811?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Swapnil Ghike updated KAFKA-811:
Attachment: kafka-811-v2.patch
Can we check in this patch ? The 1st one had a real stupid mistake.
[
https://issues.apache.org/jira/browse/KAFKA-813?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13606672#comment-13606672
]
Swapnil Ghike commented on KAFKA-813:
-
@Neha: 2. If the target state is not OfflinePart
[
https://issues.apache.org/jira/browse/KAFKA-813?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13606649#comment-13606649
]
Neha Narkhede commented on KAFKA-813:
-
Thanks for the cleanup patch, Swapnil. Here are
[
https://issues.apache.org/jira/browse/KAFKA-812?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13606613#comment-13606613
]
Neha Narkhede commented on KAFKA-812:
-
Looks good, +1. Please can you fix some code sty
Sriram Subramanian created KAFKA-814:
Summary: Controller should not throw exception when a preferred
replica is already the leader for a partition
Key: KAFKA-814
URL: https://issues.apache.org/jira/browse/KAF
[
https://issues.apache.org/jira/browse/KAFKA-813?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13606514#comment-13606514
]
Jun Rao commented on KAFKA-813:
---
Thanks for the patch. Some comments:
1. For 1 and 2, it see
[
https://issues.apache.org/jira/browse/KAFKA-802?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Neha Narkhede closed KAFKA-802.
---
> 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:
Resolution: Fixed
Status: Resolved (was: Patch Available)
> Flush message interval is b
This is planned after a 0.8.1 release as part of a major 0.9 release. This
is because the client APIs might change due to the improvements in the
client redesign. This work is probably at least 6 months out from now.
Thanks,
Neha
On Tue, Mar 19, 2013 at 8:25 AM, 刘杰 wrote:
> the two branches ar
the two branches are both very excellent work, is there a merger roadmap,
when?
I was approached by a publisher the other day to do a book on Kafka -
something I've actually thought about pursuing. Before I say yes (or
consider saying yes), I wanted to make sure no one else was working on a
book. No sense in producing competing texts at this point.
So, anyone working on a
42 matches
Mail list logo
