[
https://issues.apache.org/jira/browse/KAFKA-10889?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jiangjie Qin resolved KAFKA-10889.
--
Resolution: Not A Bug
I am closing the issue as not a bug because the brokers were working as
[
https://issues.apache.org/jira/browse/KAFKA-10889?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17255919#comment-17255919
]
Jiangjie Qin commented on KAFKA-10889:
--
[~wenbing.shen] You can achieve this by setting the
[
https://issues.apache.org/jira/browse/KAFKA-10889?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17255527#comment-17255527
]
Jiangjie Qin commented on KAFKA-10889:
--
It looks that the broker is working as design. I am not
[
https://issues.apache.org/jira/browse/KAFKA-9703?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jiangjie Qin reassigned KAFKA-9703:
---
Fix Version/s: 2.6.0
Assignee: jiamei xie
Resolution: Fixed
Just to make it
[
https://issues.apache.org/jira/browse/KAFKA-6029?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jiangjie Qin updated KAFKA-6029:
Fix Version/s: 2.2.0
> Controller should wait for the leader migration to finish before ack a
>
[
https://issues.apache.org/jira/browse/KAFKA-6029?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jiangjie Qin resolved KAFKA-6029.
-
Resolution: Fixed
> Controller should wait for the leader migration to finish before ack a
>
[
https://issues.apache.org/jira/browse/KAFKA-6029?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16848809#comment-16848809
]
Jiangjie Qin commented on KAFKA-6029:
-
[~hachikuji] Yes, I think the issue should have been resolved.
[
https://issues.apache.org/jira/browse/KAFKA-5453?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16710023#comment-16710023
]
Jiangjie Qin commented on KAFKA-5453:
-
[~viktorsomogyi] Sure. Go ahead. Thanks for being interested
[
https://issues.apache.org/jira/browse/KAFKA-5453?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jiangjie Qin reassigned KAFKA-5453:
---
Assignee: Viktor Somogyi
> Controller may miss requests sent to the broker when zk session
[
https://issues.apache.org/jira/browse/KAFKA-5886?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16543403#comment-16543403
]
Jiangjie Qin commented on KAFKA-5886:
-
[~yuyang08] I just added you to the contributor list. You
[
https://issues.apache.org/jira/browse/KAFKA-5886?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jiangjie Qin reassigned KAFKA-5886:
---
Assignee: Yu Yang (was: Sumant Tambe)
> Introduce delivery.timeout.ms producer config
[
https://issues.apache.org/jira/browse/KAFKA-2200?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16467022#comment-16467022
]
Jiangjie Qin commented on KAFKA-2200:
-
[~anurag_iit2k] Sure, please feel free to take this ticket.
>
[
https://issues.apache.org/jira/browse/KAFKA-2200?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16467020#comment-16467020
]
Jiangjie Qin commented on KAFKA-2200:
-
[~PnPie] Sorry about the belated response. Yes, you are right,
[
https://issues.apache.org/jira/browse/KAFKA-6588?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jiangjie Qin reassigned KAFKA-6588:
---
Assignee: Navina Ramesh
> Add a metric to monitor live log cleaner thread
>
[
https://issues.apache.org/jira/browse/KAFKA-6568?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jiangjie Qin updated KAFKA-6568:
Description: {{LogCleanerManager.doneDeleting()}} removes the partition
from the {{inProgress}} map
Jiangjie Qin created KAFKA-6568:
---
Summary: LogCleanerManager.doneDeleting() should check the
partition state before deleting the in progress partition
Key: KAFKA-6568
URL:
[
https://issues.apache.org/jira/browse/KAFKA-6489?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jiangjie Qin resolved KAFKA-6489.
-
Resolution: Fixed
> Fetcher.retrieveOffsetsByTimes() should add all the topics to the metadata
>
[
https://issues.apache.org/jira/browse/KAFKA-6489?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16348949#comment-16348949
]
Jiangjie Qin commented on KAFKA-6489:
-
[~damianguy] Can we include this in 1.1? This patch is
[
https://issues.apache.org/jira/browse/KAFKA-6489?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jiangjie Qin updated KAFKA-6489:
Fix Version/s: (was: 1.2.0)
1.1.0
> Fetcher.retrieveOffsetsByTimes() should
[
https://issues.apache.org/jira/browse/KAFKA-6492?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jiangjie Qin updated KAFKA-6492:
Affects Version/s: 0.10.0.2
0.10.1.1
0.10.2.1
[
https://issues.apache.org/jira/browse/KAFKA-6492?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16347670#comment-16347670
]
Jiangjie Qin commented on KAFKA-6492:
-
[~hachikuji] You are right. This issue will affect earlier
[
https://issues.apache.org/jira/browse/KAFKA-6492?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jiangjie Qin updated KAFKA-6492:
Affects Version/s: 1.0.0
Fix Version/s: 1.1.0
Component/s: core
>
Jiangjie Qin created KAFKA-6492:
---
Summary: LogSemgent.truncateTo() should always resize the index
file
Key: KAFKA-6492
URL: https://issues.apache.org/jira/browse/KAFKA-6492
Project: Kafka
Jiangjie Qin created KAFKA-6489:
---
Summary: Fetcher.retrieveOffsetsByTimes() should add all the
topics to the metadata refresh topics set.
Key: KAFKA-6489
URL: https://issues.apache.org/jira/browse/KAFKA-6489
[
https://issues.apache.org/jira/browse/KAFKA-6264?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jiangjie Qin updated KAFKA-6264:
Fix Version/s: 1.1.0
> Log cleaner thread may die on legacy segment containing messages whose
>
[
https://issues.apache.org/jira/browse/KAFKA-6264?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jiangjie Qin updated KAFKA-6264:
Fix Version/s: (was: 1.0.1)
1.1.0
1.0.2
> Log cleaner
[
https://issues.apache.org/jira/browse/KAFKA-6264?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jiangjie Qin updated KAFKA-6264:
Fix Version/s: (was: 1.1.0)
> Log cleaner thread may die on legacy segment containing messages
[
https://issues.apache.org/jira/browse/KAFKA-6264?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16335046#comment-16335046
]
Jiangjie Qin commented on KAFKA-6264:
-
[~ewencp] The impact of this issue is nasty but the chance of
[
https://issues.apache.org/jira/browse/KAFKA-6264?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16335046#comment-16335046
]
Jiangjie Qin edited comment on KAFKA-6264 at 1/22/18 10:31 PM:
---
[~ewencp]
Jiangjie Qin created KAFKA-6321:
---
Summary: ConsumerGroupCommand should use the new consumer to query
the log end offsets.
Key: KAFKA-6321
URL: https://issues.apache.org/jira/browse/KAFKA-6321
Project:
[
https://issues.apache.org/jira/browse/KAFKA-6304?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jiangjie Qin updated KAFKA-6304:
Summary: The controller should allow updating the partition reassignment
for the partitions being
Jiangjie Qin created KAFKA-6304:
---
Summary: The controller should allow update the partition
reassignment for the partitions being reassigned
Key: KAFKA-6304
URL: https://issues.apache.org/jira/browse/KAFKA-6304
[
https://issues.apache.org/jira/browse/KAFKA-6304?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jiangjie Qin updated KAFKA-6304:
Affects Version/s: 1.0.0
Fix Version/s: 1.1.0
Component/s: core
Jiangjie Qin created KAFKA-6264:
---
Summary: Log cleaner thread may die on legacy segment containing
messages whose offsets are too large
Key: KAFKA-6264
URL: https://issues.apache.org/jira/browse/KAFKA-6264
[
https://issues.apache.org/jira/browse/KAFKA-3554?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16257400#comment-16257400
]
Jiangjie Qin commented on KAFKA-3554:
-
[~airbots] Thanks for volunteer to help. The patch needs a
[
https://issues.apache.org/jira/browse/KAFKA-6157?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jiangjie Qin resolved KAFKA-6157.
-
Resolution: Fixed
> Fix repeated words words in JavaDoc and comments.
>
[
https://issues.apache.org/jira/browse/KAFKA-6083?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jiangjie Qin reassigned KAFKA-6083:
---
Assignee: Adem Efe Gencer
> The Fetcher should add the InvalidRecordException as a cause to
Jiangjie Qin created KAFKA-6083:
---
Summary: The Fetcher should add the InvalidRecordException as a
cause to the KafkaException when invalid record is found.
Key: KAFKA-6083
URL:
[
https://issues.apache.org/jira/browse/KAFKA-6028?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16199806#comment-16199806
]
Jiangjie Qin commented on KAFKA-6028:
-
[~junrao] We were thinking that the server will mute the
[
https://issues.apache.org/jira/browse/KAFKA-6028?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16199712#comment-16199712
]
Jiangjie Qin commented on KAFKA-6028:
-
[~junrao] Not sure if this is going to solve the problem. The
[
https://issues.apache.org/jira/browse/KAFKA-6029?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16199706#comment-16199706
]
Jiangjie Qin commented on KAFKA-6029:
-
[~junrao] Good point. That seems more likely to happen. Just to
Jiangjie Qin created KAFKA-6029:
---
Summary: Controller should wait for the leader migration to finish
before ack a ControlledShutdownRequest
Key: KAFKA-6029
URL: https://issues.apache.org/jira/browse/KAFKA-6029
Jiangjie Qin created KAFKA-6028:
---
Summary: Improve the quota throttle communication.
Key: KAFKA-6028
URL: https://issues.apache.org/jira/browse/KAFKA-6028
Project: Kafka
Issue Type:
[
https://issues.apache.org/jira/browse/KAFKA-2200?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16175474#comment-16175474
]
Jiangjie Qin commented on KAFKA-2200:
-
[~andy.chamb...@fundingcircle.com] Feel free to take the
[
https://issues.apache.org/jira/browse/KAFKA-5886?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16175117#comment-16175117
]
Jiangjie Qin commented on KAFKA-5886:
-
[~guozhang] The patch is still going through review iterations.
Jiangjie Qin created KAFKA-5782:
---
Summary: Avoid unnecessary PID reset when expire batches.
Key: KAFKA-5782
URL: https://issues.apache.org/jira/browse/KAFKA-5782
Project: Kafka
Issue Type:
[
https://issues.apache.org/jira/browse/KAFKA-5681?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16114950#comment-16114950
]
Jiangjie Qin commented on KAFKA-5681:
-
[~ijuma] The confusion part is that we have always been
[
https://issues.apache.org/jira/browse/KAFKA-5678?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16113064#comment-16113064
]
Jiangjie Qin commented on KAFKA-5678:
-
[~cuiyang]
1. Currently request timeout is used in two
[
https://issues.apache.org/jira/browse/KAFKA-5678?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16111891#comment-16111891
]
Jiangjie Qin commented on KAFKA-5678:
-
[~cuiyang] There might be a few things to consider here, the
[
https://issues.apache.org/jira/browse/KAFKA-5678?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16110075#comment-16110075
]
Jiangjie Qin commented on KAFKA-5678:
-
[~guozhang] Likely KAFKA- should solve the problem, but if
[
https://issues.apache.org/jira/browse/KAFKA-5678?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16109910#comment-16109910
]
Jiangjie Qin edited comment on KAFKA-5678 at 8/1/17 10:34 PM:
--
That's right.
[
https://issues.apache.org/jira/browse/KAFKA-5678?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16109910#comment-16109910
]
Jiangjie Qin commented on KAFKA-5678:
-
That's right. I was under the impression that KAFKA- has
[
https://issues.apache.org/jira/browse/KAFKA-5621?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16108156#comment-16108156
]
Jiangjie Qin commented on KAFKA-5621:
-
[~ijuma] Like [~apurva] said, for users who care about orders,
[
https://issues.apache.org/jira/browse/KAFKA-5621?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16108050#comment-16108050
]
Jiangjie Qin commented on KAFKA-5621:
-
[~apurva] Thanks for the explanation. I think we are on the
Jiangjie Qin created KAFKA-5681:
---
Summary: jarAll does not build all scala versions anymore.
Key: KAFKA-5681
URL: https://issues.apache.org/jira/browse/KAFKA-5681
Project: Kafka
Issue Type:
[
https://issues.apache.org/jira/browse/KAFKA-5678?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16107569#comment-16107569
]
Jiangjie Qin commented on KAFKA-5678:
-
[~Json Tu] [~cuiyang] In DelayedProduce.tryComplete(), it will
[
https://issues.apache.org/jira/browse/KAFKA-5678?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16106700#comment-16106700
]
Jiangjie Qin commented on KAFKA-5678:
-
[~Json Tu] Can you check if this is a duplicate problem of
[
https://issues.apache.org/jira/browse/KAFKA-1944?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16105959#comment-16105959
]
Jiangjie Qin commented on KAFKA-1944:
-
I agree with [~hachikuji] that we can deprecate
[
https://issues.apache.org/jira/browse/KAFKA-5621?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16103967#comment-16103967
]
Jiangjie Qin commented on KAFKA-5621:
-
[~apurva] I am trying to understand the following statement
[
https://issues.apache.org/jira/browse/KAFKA-5621?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16102176#comment-16102176
]
Jiangjie Qin commented on KAFKA-5621:
-
[~apurva] Yes, I agree that expiry ms is a new concept as it is
[
https://issues.apache.org/jira/browse/KAFKA-5621?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16101932#comment-16101932
]
Jiangjie Qin commented on KAFKA-5621:
-
[~ijuma] [~apurva] The expiration for messages in the
[
https://issues.apache.org/jira/browse/KAFKA-5627?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jiangjie Qin resolved KAFKA-5627.
-
Resolution: Fixed
> Reduce classes needed for LeaderAndIsrPartitionState and
>
[
https://issues.apache.org/jira/browse/KAFKA-5630?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jiangjie Qin reassigned KAFKA-5630:
---
Assignee: Jiangjie Qin
> Consumer poll loop over the same record after a
[
https://issues.apache.org/jira/browse/KAFKA-5630?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16098990#comment-16098990
]
Jiangjie Qin commented on KAFKA-5630:
-
[~vmaurin_glispa] Thanks for reporting the issue. It looks that
64 matches
Mail list logo
