[
https://issues.apache.org/jira/browse/KAFKA-1729?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Joel Koshy updated KAFKA-1729:
--
Attachment: KAFKA-1782-doc-v1.patch
Uploading v1 for review
> add doc for Kafka-based offset management
[
https://issues.apache.org/jira/browse/KAFKA-1706?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Joel Koshy updated KAFKA-1706:
--
Resolution: Fixed
Status: Resolved (was: Patch Available)
Thanks for the patch. Committed to tr
[
https://issues.apache.org/jira/browse/KAFKA-1634?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Joel Koshy updated KAFKA-1634:
--
Reviewer: Joel Koshy (was: Neha Narkhede)
> Improve semantics of timestamp in OffsetCommitRequests and
[
https://issues.apache.org/jira/browse/KAFKA-1729?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14197243#comment-14197243
]
Joel Koshy commented on KAFKA-1729:
---
Thanks for reviewing.
Re: offsets in ZK
Yes we can
[
https://issues.apache.org/jira/browse/KAFKA-1729?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Joel Koshy updated KAFKA-1729:
--
Status: In Progress (was: Patch Available)
> add doc for Kafka-based offset management in 0.8.2
> -
[
https://issues.apache.org/jira/browse/KAFKA-1481?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14197412#comment-14197412
]
Joel Koshy commented on KAFKA-1481:
---
Sorry I ran out of time - will look tomorrow.
> St
Joel Koshy created KAFKA-1755:
-
Summary: Log cleaner thread should not exit on errors
Key: KAFKA-1755
URL: https://issues.apache.org/jira/browse/KAFKA-1755
Project: Kafka
Issue Type: Bug
[
https://issues.apache.org/jira/browse/KAFKA-391?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14198699#comment-14198699
]
Joel Koshy commented on KAFKA-391:
--
If there are three partitions, then there will be thre
[
https://issues.apache.org/jira/browse/KAFKA-1729?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Joel Koshy updated KAFKA-1729:
--
Attachment: KAFKA-1782-doc-v2.patch
> add doc for Kafka-based offset management in 0.8.2
> -
[
https://issues.apache.org/jira/browse/KAFKA-1729?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Joel Koshy updated KAFKA-1729:
--
Status: Patch Available (was: In Progress)
> add doc for Kafka-based offset management in 0.8.2
> -
[
https://issues.apache.org/jira/browse/KAFKA-1729?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14199616#comment-14199616
]
Joel Koshy commented on KAFKA-1729:
---
Incorporated comments. I would actually like to get
[
https://issues.apache.org/jira/browse/KAFKA-1481?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Joel Koshy updated KAFKA-1481:
--
Attachment: alternateLayout2.png
alternateLayout1.png
diff-for-alternate-
[
https://issues.apache.org/jira/browse/KAFKA-1742?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14202955#comment-14202955
]
Joel Koshy commented on KAFKA-1742:
---
+1, although one minor change:
{code}
// instead of
[
https://issues.apache.org/jira/browse/KAFKA-1742?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14207591#comment-14207591
]
Joel Koshy commented on KAFKA-1742:
---
+1 and committed to trunk and 0.8.2
Based on the r
[
https://issues.apache.org/jira/browse/KAFKA-1742?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Joel Koshy resolved KAFKA-1742.
---
Resolution: Fixed
> ControllerContext removeTopic does not correctly update state
> --
[
https://issues.apache.org/jira/browse/KAFKA-1762?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14208940#comment-14208940
]
Joel Koshy commented on KAFKA-1762:
---
Committed the doc change to trunk
> Enforce MAX_IN
[
https://issues.apache.org/jira/browse/KAFKA-1481?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14209055#comment-14209055
]
Joel Koshy commented on KAFKA-1481:
---
(1) and (4) seem equivalent (i.e., AllTopics vs Agg
[
https://issues.apache.org/jira/browse/KAFKA-1762?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Joel Koshy updated KAFKA-1762:
--
Resolution: Fixed
Status: Resolved (was: Patch Available)
> Update max-inflight-request doc str
[
https://issues.apache.org/jira/browse/KAFKA-1762?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Joel Koshy updated KAFKA-1762:
--
Summary: Update max-inflight-request doc string (was: Enforce
MAX_IN_FLIGHT_REQUESTS_PER_CONNECTION to
[
https://issues.apache.org/jira/browse/KAFKA-1481?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14211341#comment-14211341
]
Joel Koshy commented on KAFKA-1481:
---
Re: BrokerTopicMetrics so that it can be distinguis
[
https://issues.apache.org/jira/browse/KAFKA-1764?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Joel Koshy updated KAFKA-1764:
--
Description:
In ZookeeperConsumerConnector shutdown(), we could potentially put multiple
shutdownComman
[
https://issues.apache.org/jira/browse/KAFKA-1764?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14211713#comment-14211713
]
Joel Koshy commented on KAFKA-1764:
---
Committed to trunk.
[~junrao] do you think this sh
[
https://issues.apache.org/jira/browse/KAFKA-1764?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14211833#comment-14211833
]
Joel Koshy commented on KAFKA-1764:
---
That was my bad - I should have double-checked that
[
https://issues.apache.org/jira/browse/KAFKA-313?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14212527#comment-14212527
]
Joel Koshy commented on KAFKA-313:
--
I'm not sure if there is a strong need for this. In Li
[
https://issues.apache.org/jira/browse/KAFKA-313?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Joel Koshy reassigned KAFKA-313:
Assignee: Ashish Kumar Singh
> Add JSON output and looping options to ConsumerOffsetChecker
> --
[
https://issues.apache.org/jira/browse/KAFKA-313?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Joel Koshy updated KAFKA-313:
-
Reviewer: Joel Koshy
> Add JSON output and looping options to ConsumerOffsetChecker
> -
[
https://issues.apache.org/jira/browse/KAFKA-1764?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14212569#comment-14212569
]
Joel Koshy commented on KAFKA-1764:
---
Thanks for the fix. Committed to trunk and 0.8.2
>
[
https://issues.apache.org/jira/browse/KAFKA-1764?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Joel Koshy updated KAFKA-1764:
--
Resolution: Fixed
Status: Resolved (was: Patch Available)
> ZookeeperConsumerConnector could pu
[
https://issues.apache.org/jira/browse/KAFKA-1580?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Joel Koshy reopened KAFKA-1580:
---
Assignee: Guozhang Wang (was: Jonathan Natkins)
> Reject producer requests to internal topics
> ---
[
https://issues.apache.org/jira/browse/KAFKA-1580?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14212811#comment-14212811
]
Joel Koshy commented on KAFKA-1580:
---
[~guozhang] I believe this change got lost as part
[
https://issues.apache.org/jira/browse/KAFKA-1481?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14212873#comment-14212873
]
Joel Koshy commented on KAFKA-1481:
---
[~junrao] For 80.2, I believe the additional regist
[
https://issues.apache.org/jira/browse/KAFKA-1481?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14215371#comment-14215371
]
Joel Koshy commented on KAFKA-1481:
---
+1 (for 0.8.2)
> Stop using dashes AND underscore
[
https://issues.apache.org/jira/browse/KAFKA-1755?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14216486#comment-14216486
]
Joel Koshy commented on KAFKA-1755:
---
There are a couple of issues that I was thinking of
[
https://issues.apache.org/jira/browse/KAFKA-1755?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Joel Koshy updated KAFKA-1755:
--
Summary: Improve error handling in log cleaner (was: Log cleaner thread
should not exit on errors)
> I
[
https://issues.apache.org/jira/browse/KAFKA-1755?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Joel Koshy updated KAFKA-1755:
--
Assignee: Joel Koshy
> Improve error handling in log cleaner
> -
>
>
[
https://issues.apache.org/jira/browse/KAFKA-1728?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Joel Koshy updated KAFKA-1728:
--
Fix Version/s: 0.8.2
> update 082 docs
> ---
>
> Key: KAFKA-1728
>
[
https://issues.apache.org/jira/browse/KAFKA-1282?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Joel Koshy updated KAFKA-1282:
--
Fix Version/s: (was: 0.9.0)
0.8.2
This is already in 0.8.2 so we should incorpora
[
https://issues.apache.org/jira/browse/KAFKA-1580?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Joel Koshy updated KAFKA-1580:
--
Priority: Blocker (was: Major)
> Reject producer requests to internal topics
>
[
https://issues.apache.org/jira/browse/KAFKA-1580?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Joel Koshy updated KAFKA-1580:
--
Priority: Critical (was: Blocker)
> Reject producer requests to internal topics
> -
[
https://issues.apache.org/jira/browse/KAFKA-1730?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Joel Koshy updated KAFKA-1730:
--
Priority: Blocker (was: Major)
> add the doc for the new java producer in 0.8.2
> -
[
https://issues.apache.org/jira/browse/KAFKA-1728?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Joel Koshy updated KAFKA-1728:
--
Priority: Blocker (was: Major)
> update 082 docs
> ---
>
> Key: KAFKA-1728
[
https://issues.apache.org/jira/browse/KAFKA-1731?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Joel Koshy updated KAFKA-1731:
--
Priority: Blocker (was: Major)
> add config/jmx changes in 0.8.2 doc
>
Joel Koshy created KAFKA-1784:
-
Summary: Implement a ConsumerOffsetClient library
Key: KAFKA-1784
URL: https://issues.apache.org/jira/browse/KAFKA-1784
Project: Kafka
Issue Type: New Feature
Joel Koshy created KAFKA-1785:
-
Summary: Consumer offset checker should show the offset manager
and offsets partition
Key: KAFKA-1785
URL: https://issues.apache.org/jira/browse/KAFKA-1785
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-1785?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Joel Koshy updated KAFKA-1785:
--
Fix Version/s: 0.8.2
> Consumer offset checker should show the offset manager and offsets partition
> --
[
https://issues.apache.org/jira/browse/KAFKA-1580?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Joel Koshy updated KAFKA-1580:
--
Reviewer: Joel Koshy
> Reject producer requests to internal topics
> ---
Joel Koshy created KAFKA-1787:
-
Summary: Consumer should delete offsets and release partition
ownership for deleted topics
Key: KAFKA-1787
URL: https://issues.apache.org/jira/browse/KAFKA-1787
Project: Ka
[
https://issues.apache.org/jira/browse/KAFKA-1787?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Joel Koshy reassigned KAFKA-1787:
-
Assignee: Onur Karaman
> Consumer should delete offsets and release partition ownership for delet
[
https://issues.apache.org/jira/browse/KAFKA-1787?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14231088#comment-14231088
]
Joel Koshy commented on KAFKA-1787:
---
Yeah that is one issue; [~onurkaraman] and I had di
[
https://issues.apache.org/jira/browse/KAFKA-1787?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Joel Koshy resolved KAFKA-1787.
---
Resolution: Won't Fix
> Consumer should delete offsets and release partition ownership for deleted
>
[
https://issues.apache.org/jira/browse/KAFKA-1784?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14232060#comment-14232060
]
Joel Koshy commented on KAFKA-1784:
---
It does not need to be a blocker but would be good
[
https://issues.apache.org/jira/browse/KAFKA-1790?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=1423#comment-1423
]
Joel Koshy commented on KAFKA-1790:
---
One possibility is to allow sending ControlledShutd
[
https://issues.apache.org/jira/browse/KAFKA-1720?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Joel Koshy updated KAFKA-1720:
--
Resolution: Fixed
Status: Resolved (was: Patch Available)
Guozhang committed this to trunk
> [
[
https://issues.apache.org/jira/browse/KAFKA-1819?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14247925#comment-14247925
]
Joel Koshy commented on KAFKA-1819:
---
This is a similar stack-trace to KAFKA-1641 but tha
[
https://issues.apache.org/jira/browse/KAFKA-1819?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14249530#comment-14249530
]
Joel Koshy commented on KAFKA-1819:
---
[~gwenshap] that's right - that's what I meant by "
[
https://issues.apache.org/jira/browse/KAFKA-1499?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14249536#comment-14249536
]
Joel Koshy commented on KAFKA-1499:
---
Thank you for the ping, and sorry about the delayed
[
https://issues.apache.org/jira/browse/KAFKA-1823?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14251549#comment-14251549
]
Joel Koshy commented on KAFKA-1823:
---
This was caused by KAFKA-1684 - it can be reproduce
[
https://issues.apache.org/jira/browse/KAFKA-1823?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Joel Koshy updated KAFKA-1823:
--
Attachment: KAFKA-1823.patch
> transient unit test failure in PartitionAssignorTest
> --
[
https://issues.apache.org/jira/browse/KAFKA-1823?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Joel Koshy updated KAFKA-1823:
--
Assignee: Joel Koshy
Status: Patch Available (was: Open)
> transient unit test failure in Partiti
[
https://issues.apache.org/jira/browse/KAFKA-1823?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14251551#comment-14251551
]
Joel Koshy commented on KAFKA-1823:
---
Created reviewboard https://reviews.apache.org/r/29
[
https://issues.apache.org/jira/browse/KAFKA-1823?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14251549#comment-14251549
]
Joel Koshy edited comment on KAFKA-1823 at 12/18/14 11:43 AM:
--
[
https://issues.apache.org/jira/browse/KAFKA-1755?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14256890#comment-14256890
]
Joel Koshy commented on KAFKA-1755:
---
Thanks for the comments. The issue with 3a is that
[
https://issues.apache.org/jira/browse/KAFKA-1650?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Joel Koshy updated KAFKA-1650:
--
Resolution: Fixed
Status: Resolved (was: Patch Available)
Committed to trunk
> Mirror Maker co
[
https://issues.apache.org/jira/browse/KAFKA-1782?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14258955#comment-14258955
]
Joel Koshy commented on KAFKA-1782:
---
I think it would be beneficial to at least survey a
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-827?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13614434#comment-13614434
]
Joel Koshy commented on KAFKA-827:
--
While you are touching this, would it be reasonable to
[
https://issues.apache.org/jira/browse/KAFKA-826?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13616783#comment-13616783
]
Joel Koshy commented on KAFKA-826:
--
Thank you for looking into this. Metrics 2.x had a few
Joel Koshy created KAFKA-872:
Summary: Socket server does not set send/recv buffer sizes
Key: KAFKA-872
URL: https://issues.apache.org/jira/browse/KAFKA-872
Project: Kafka
Issue Type: Bug
[
https://issues.apache.org/jira/browse/KAFKA-872?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Joel Koshy updated KAFKA-872:
-
Attachment: KAFKA-872-v1.patch
> Socket server does not set send/recv buffer sizes
> -
[
https://issues.apache.org/jira/browse/KAFKA-872?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Joel Koshy resolved KAFKA-872.
--
Resolution: Fixed
Thanks for the review. Applied to 0.8.
> Socket server does not set s
Joel Koshy created KAFKA-880:
Summary: NoLeaderPartitionSet should be cleared before leader
finder thread is started up
Key: KAFKA-880
URL: https://issues.apache.org/jira/browse/KAFKA-880
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-880?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Joel Koshy updated KAFKA-880:
-
Description:
This was a recent regression.
This could prevent the consumer from progressing because fetch
[
https://issues.apache.org/jira/browse/KAFKA-890?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13645736#comment-13645736
]
Joel Koshy commented on KAFKA-890:
--
+1
It is worth noting that this is useful even in the
[
https://issues.apache.org/jira/browse/KAFKA-889?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13646080#comment-13646080
]
Joel Koshy commented on KAFKA-889:
--
+1
> Add mbeans to track socket serve
[
https://issues.apache.org/jira/browse/KAFKA-886?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13646092#comment-13646092
]
Joel Koshy commented on KAFKA-886:
--
Thanks for the great write-up. Couple of comments:
1)
[
https://issues.apache.org/jira/browse/KAFKA-892?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13646192#comment-13646192
]
Joel Koshy commented on KAFKA-892:
--
+1
> Change request log to include re
[
https://issues.apache.org/jira/browse/KAFKA-901?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13654667#comment-13654667
]
Joel Koshy commented on KAFKA-901:
--
Haven't looked at the patch yet, but went through the
Joel Koshy created KAFKA-914:
Summary: Deadlock between initial rebalance and watcher-triggered
rebalances
Key: KAFKA-914
URL: https://issues.apache.org/jira/browse/KAFKA-914
Project: Kafka
Issu
[
https://issues.apache.org/jira/browse/KAFKA-914?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13663146#comment-13663146
]
Joel Koshy commented on KAFKA-914:
--
One more point: [td3] above does not need to originate
[
https://issues.apache.org/jira/browse/KAFKA-914?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Joel Koshy updated KAFKA-914:
-
Attachment: KAFKA-914-v1.patch
Patch with the mentioned fix.
1 - I added comments with some detail since
Joel Koshy created KAFKA-916:
Summary: Deadlock between fetcher shutdown and handling partitions
with error
Key: KAFKA-916
URL: https://issues.apache.org/jira/browse/KAFKA-916
Project: Kafka
Iss
[
https://issues.apache.org/jira/browse/KAFKA-914?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Joel Koshy resolved KAFKA-914.
--
Resolution: Fixed
Thanks for the review. Committed after removing the unnecessary assignment in
MirrorM
[
https://issues.apache.org/jira/browse/KAFKA-914?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Joel Koshy closed KAFKA-914.
> Deadlock between initial rebalance and watcher-triggered rebalances
>
[
https://issues.apache.org/jira/browse/KAFKA-911?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13666532#comment-13666532
]
Joel Koshy commented on KAFKA-911:
--
I had to revisit the notes from KAFKA-340. I think thi
[
https://issues.apache.org/jira/browse/KAFKA-916?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Joel Koshy updated KAFKA-916:
-
Attachment: KAFKA-916-v1.patch
Agreed - I think that should fix the issue.
> Deadlock bet
[
https://issues.apache.org/jira/browse/KAFKA-916?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Joel Koshy closed KAFKA-916.
Thanks for the review. Committed to 0.8
> Deadlock between fetcher shutdown and handling partit
[
https://issues.apache.org/jira/browse/KAFKA-916?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Joel Koshy resolved KAFKA-916.
--
Resolution: Fixed
> Deadlock between fetcher shutdown and handling partitions with error
> -
Joel Koshy created KAFKA-921:
Summary: Expose max lag mbean for consumers and replica fetchers
Key: KAFKA-921
URL: https://issues.apache.org/jira/browse/KAFKA-921
Project: Kafka
Issue Type: Bug
[
https://issues.apache.org/jira/browse/KAFKA-921?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Joel Koshy updated KAFKA-921:
-
Attachment: KAFKA-921-v1.patch
This provides a max lag mbean for both consumer fetcher manager and replica
[
https://issues.apache.org/jira/browse/KAFKA-921?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Joel Koshy updated KAFKA-921:
-
Attachment: KAFKA-921-v2.patch
Yes - I think that would be better. Moved it to AbstractFetcherManager. So
[
https://issues.apache.org/jira/browse/KAFKA-921?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Joel Koshy updated KAFKA-921:
-
Attachment: KAFKA-921-v3.patch
One caveat in this approach is that if a fetcher is wedged for any reason,
[
https://issues.apache.org/jira/browse/KAFKA-921?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Joel Koshy updated KAFKA-921:
-
Status: Patch Available (was: Open)
> Expose max lag mbean for consumers and replica fetchers
> -
[
https://issues.apache.org/jira/browse/KAFKA-921?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Joel Koshy closed KAFKA-921.
> Expose max lag mbean for consumers and replica fetchers
>
[
https://issues.apache.org/jira/browse/KAFKA-921?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Joel Koshy updated KAFKA-921:
-
Resolution: Fixed
Status: Resolved (was: Patch Available)
Thanks for the reviews. Committed with
[
https://issues.apache.org/jira/browse/KAFKA-927?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13674598#comment-13674598
]
Joel Koshy commented on KAFKA-927:
--
+1 - sorry I got to this late.
Small nit: the scalado
[
https://issues.apache.org/jira/browse/KAFKA-938?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13681479#comment-13681479
]
Joel Koshy commented on KAFKA-938:
--
Excellent catch Sam!
One comment: I think the Delayed
[
https://issues.apache.org/jira/browse/KAFKA-938?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13681497#comment-13681497
]
Joel Koshy commented on KAFKA-938:
--
Actually, small correction: I overlooked that the dela
[
https://issues.apache.org/jira/browse/KAFKA-937?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13681787#comment-13681787
]
Joel Koshy commented on KAFKA-937:
--
+1 on the patch.
Additionally, can you make this smal
Joel Koshy created KAFKA-940:
Summary: Scala match error in javaapi.Implicits
Key: KAFKA-940
URL: https://issues.apache.org/jira/browse/KAFKA-940
Project: Kafka
Issue Type: Bug
Affects Versio
[
https://issues.apache.org/jira/browse/KAFKA-940?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Joel Koshy updated KAFKA-940:
-
Attachment: KAFKA-940-v1.patch
Simple fix.
> Scala match error in javaapi.Implicits
> ---
601 - 700 of 848 matches
Mail list logo
