[
https://issues.apache.org/jira/browse/KAFKA-13896?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17544197#comment-17544197
]
lqjacklee commented on KAFKA-13896:
---
[~mumrah] In order to downgrade , can we get the target
[
https://issues.apache.org/jira/browse/KAFKA-13884?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17542168#comment-17542168
]
lqjacklee edited comment on KAFKA-13884 at 5/25/22 6:17 PM:
[~jagsancio] I
[
https://issues.apache.org/jira/browse/KAFKA-13884?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17542168#comment-17542168
]
lqjacklee commented on KAFKA-13884:
---
[~jagsancio] I plan add observer.refresh.time.ms in the
[
https://issues.apache.org/jira/browse/KAFKA-13888?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17542111#comment-17542111
]
lqjacklee commented on KAFKA-13888:
---
[~Niket Goel] https://github.com/apache/kafka/pull/12212 please
[
https://issues.apache.org/jira/browse/KAFKA-13888?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
lqjacklee reassigned KAFKA-13888:
-
Assignee: lqjacklee (was: Niket Goel)
> KIP-836: Addition of Information in
[
https://issues.apache.org/jira/browse/KAFKA-13888?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17541841#comment-17541841
]
lqjacklee commented on KAFKA-13888:
---
[~Niket Goel] thanks your reply. I will continue the work.
[
https://issues.apache.org/jira/browse/KAFKA-13888?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17540910#comment-17540910
]
lqjacklee commented on KAFKA-13888:
---
[~Niket Goel] can I take the task ? I am working on this task.
[
https://issues.apache.org/jira/browse/KAFKA-13888?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17539465#comment-17539465
]
lqjacklee commented on KAFKA-13888:
---
[~Niket Goel] for the field ‘LastCaughtUpTimestamp’ , how can i
[
https://issues.apache.org/jira/browse/KAFKA-13864?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17538542#comment-17538542
]
lqjacklee commented on KAFKA-13864:
---
[~frosiere] sorry late to reply , I have just resolved the VPN
[
https://issues.apache.org/jira/browse/KAFKA-13888?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17534847#comment-17534847
]
lqjacklee commented on KAFKA-13888:
---
{code:java}
// code placeholder
{code}
[~Niket Goel] I have two
[
https://issues.apache.org/jira/browse/KAFKA-13888?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17534847#comment-17534847
]
lqjacklee edited comment on KAFKA-13888 at 5/11/22 12:06 PM:
-
[~Niket Goel]
[
https://issues.apache.org/jira/browse/KAFKA-13886?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17533200#comment-17533200
]
lqjacklee commented on KAFKA-13886:
---
https://github.com/apache/kafka/pull/12133
> improve the
lqjacklee created KAFKA-13886:
-
Summary: improve the performance
org.apache.kafka.common.utils.Utils#isEqualConstantTime
Key: KAFKA-13886
URL: https://issues.apache.org/jira/browse/KAFKA-13886
Project:
[
https://issues.apache.org/jira/browse/KAFKA-13871?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
lqjacklee reassigned KAFKA-13871:
-
Assignee: lqjacklee
> The documentation for the configuration item QUORUM_FETCH_TIMEOUT of the
[
https://issues.apache.org/jira/browse/KAFKA-13864?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
lqjacklee updated KAFKA-13864:
--
Attachment: (was: interceptor_constructor_client.patch)
> Change the visibility of a
[
https://issues.apache.org/jira/browse/KAFKA-13864?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17532216#comment-17532216
]
lqjacklee commented on KAFKA-13864:
---
[~frosiere] [~cadonna] please help review the code , thanks .
[
https://issues.apache.org/jira/browse/KAFKA-13864?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17530689#comment-17530689
]
lqjacklee commented on KAFKA-13864:
---
[~frosiere] [~cadonna] please help review the patch. Once we
[
https://issues.apache.org/jira/browse/KAFKA-13864?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
lqjacklee updated KAFKA-13864:
--
Attachment: interceptor_constructor_client.patch
> Change the visibility of a KafkaProducer and
[
https://issues.apache.org/jira/browse/KAFKA-13864?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
lqjacklee reassigned KAFKA-13864:
-
Assignee: lqjacklee
> Change the visibility of a KafkaProducer and KafkaConsumer constructor
>
[
https://issues.apache.org/jira/browse/KAFKA-13860?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
lqjacklee updated KAFKA-13860:
--
Description:
try to replay the issue
* 1, startup cluster with broker 1, 2
* 2, create topic a
[
https://issues.apache.org/jira/browse/KAFKA-13860?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
lqjacklee updated KAFKA-13860:
--
Description:
try to replay the issue
* 1, startup cluster with broker 1, 2
* 2, create topic a
lqjacklee created KAFKA-13860:
-
Summary: add Decommissioning feature to
kafka-reassign-partitions.sh
Key: KAFKA-13860
URL: https://issues.apache.org/jira/browse/KAFKA-13860
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-7988?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17529449#comment-17529449
]
lqjacklee commented on KAFKA-7988:
--
why exist the same thread name ?
{code:java}
Invalid threads:
[
https://issues.apache.org/jira/browse/KAFKA-13745?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17529252#comment-17529252
]
lqjacklee commented on KAFKA-13745:
---
[~sagarrao] I want to add the log warning to catch the exception
[
https://issues.apache.org/jira/browse/KAFKA-12257?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
lqjacklee updated KAFKA-12257:
--
Attachment: KAFKA-12257-1.patch
> Consumer mishandles topics deleted and recreated with the same
[
https://issues.apache.org/jira/browse/KAFKA-12257?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
lqjacklee updated KAFKA-12257:
--
Attachment: KAFKA-12257.patch
> Consumer mishandles topics deleted and recreated with the same name
[
https://issues.apache.org/jira/browse/KAFKA-12257?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
lqjacklee reassigned KAFKA-12257:
-
Assignee: lqjacklee
> Consumer mishandles topics deleted and recreated with the same name
>
[
https://issues.apache.org/jira/browse/KAFKA-10827?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
lqjacklee updated KAFKA-10827:
--
Attachment: KAFKA-10827.patch
> Consumer group coordinator node never gets updated for manual
[
https://issues.apache.org/jira/browse/KAFKA-10827?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17263926#comment-17263926
]
lqjacklee commented on KAFKA-10827:
---
[~jaebinyo] I have create the test case to replay the case. could
[
https://issues.apache.org/jira/browse/KAFKA-10827?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
lqjacklee updated KAFKA-10827:
--
Attachment: KAFKA-10827.patch
> Consumer group coordinator node never gets updated for manual
[
https://issues.apache.org/jira/browse/KAFKA-10827?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17246250#comment-17246250
]
lqjacklee commented on KAFKA-10827:
---
[~jaebinyo] If we are in the bad network environment, will we get
[
https://issues.apache.org/jira/browse/KAFKA-10827?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
lqjacklee reassigned KAFKA-10827:
-
Assignee: lqjacklee
> Consumer group coordinator node never gets updated for manual partition
[
https://issues.apache.org/jira/browse/KAFKA-10827?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
lqjacklee updated KAFKA-10827:
--
Attachment: KAFKA-10827.patch
> Consumer group coordinator node never gets updated for manual
[
https://issues.apache.org/jira/browse/KAFKA-10824?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17246238#comment-17246238
]
lqjacklee edited comment on KAFKA-10824 at 12/9/20, 1:50 AM:
-
[
https://issues.apache.org/jira/browse/KAFKA-10824?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
lqjacklee reassigned KAFKA-10824:
-
Assignee: lqjacklee
> Connection to node -1 could not be established. Broker may not be
[
https://issues.apache.org/jira/browse/KAFKA-10824?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17246238#comment-17246238
]
lqjacklee commented on KAFKA-10824:
---
[~mohammadabboud] I can infer based on
* If 'closeMode'
[
https://issues.apache.org/jira/browse/KAFKA-10765?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
lqjacklee reassigned KAFKA-10765:
-
Assignee: lqjacklee
> Task :stream:test-utils:test FAILED
>
[
https://issues.apache.org/jira/browse/KAFKA-10765?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17238553#comment-17238553
]
lqjacklee commented on KAFKA-10765:
---
[~xiaopenglei]
{code:java}
2119 ± : ./gradlew
[
https://issues.apache.org/jira/browse/KAFKA-10753?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17237888#comment-17237888
]
lqjacklee commented on KAFKA-10753:
---
[~dengziming] From my opinion , in the task we should just force
lqjacklee created KAFKA-10762:
-
Summary: alter the backoff in `KafkaConsumer.pollForFetches`
Key: KAFKA-10762
URL: https://issues.apache.org/jira/browse/KAFKA-10762
Project: Kafka
Issue Type:
[
https://issues.apache.org/jira/browse/KAFKA-10753?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17237792#comment-17237792
]
lqjacklee commented on KAFKA-10753:
---
[~17hao] I have uploaded the patch to cover the case. however
[
https://issues.apache.org/jira/browse/KAFKA-10753?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
lqjacklee updated KAFKA-10753:
--
Attachment: KAFKA-10753.patch
> check if ConsumerConfig.AUTO_COMMIT_INTERVAL_MS_CONFIG > 0
>
[
https://issues.apache.org/jira/browse/KAFKA-10753?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17237054#comment-17237054
]
lqjacklee commented on KAFKA-10753:
---
[~dengziming] should we create another jira to track the issue?
[
https://issues.apache.org/jira/browse/KAFKA-10753?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17236189#comment-17236189
]
lqjacklee commented on KAFKA-10753:
---
{code:java}
public void reset(long timeoutMs) {
if
[
https://issues.apache.org/jira/browse/KAFKA-10753?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17235946#comment-17235946
]
lqjacklee commented on KAFKA-10753:
---
[~showuon] org.apache.kafka.common.utils.Time need check whether
[
https://issues.apache.org/jira/browse/KAFKA-10753?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
lqjacklee reassigned KAFKA-10753:
-
Assignee: lqjacklee
> check if ConsumerConfig.AUTO_COMMIT_INTERVAL_MS_CONFIG != 0
>
[
https://issues.apache.org/jira/browse/KAFKA-10726?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17233300#comment-17233300
]
lqjacklee commented on KAFKA-10726:
---
If you are seeing excessive pauses during garbage collection, you
[
https://issues.apache.org/jira/browse/KAFKA-10666?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17233277#comment-17233277
]
lqjacklee commented on KAFKA-10666:
---
[~pfjason] Does https://issues.apache.org/jira/browse/KAFKA-10700
[
https://issues.apache.org/jira/browse/KAFKA-10713?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17231322#comment-17231322
]
lqjacklee commented on KAFKA-10713:
---
the bootstrap.servers should configured with Split data with
[
https://issues.apache.org/jira/browse/KAFKA-10694?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17229630#comment-17229630
]
lqjacklee commented on KAFKA-10694:
---
[~jagsancio] thanks a lot .
> Implement zero copy for
[
https://issues.apache.org/jira/browse/KAFKA-10694?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17229029#comment-17229029
]
lqjacklee commented on KAFKA-10694:
---
[~jagsancio] Can I take the task?
> Implement zero copy for
[
https://issues.apache.org/jira/browse/KAFKA-10666?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17224605#comment-17224605
]
lqjacklee commented on KAFKA-10666:
---
[~pfjason] checked the code. we just load the configuration from
lqjacklee created KAFKA-10208:
-
Summary:
org.apache.kafka.clients.consumer.internals.ConsumerCoordinator.OffsetFetchResponseHandler
return null when Broker unexpectedly doesn't support requireStable flag on
version while not any information
lqjacklee created KAFKA-10145:
-
Summary: Enhance to support the multiple join operation
Key: KAFKA-10145
URL: https://issues.apache.org/jira/browse/KAFKA-10145
Project: Kafka
Issue Type:
54 matches
Mail list logo
