[
https://issues.apache.org/jira/browse/KAFKA-13896?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17544197#comment-17544197
]
lqjacklee commented on KAFKA-13896:
---
[~mumrah] In order to downgrade , can we get the
[
https://issues.apache.org/jira/browse/KAFKA-13884?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17542168#comment-17542168
]
lqjacklee edited comment on KAFKA-13884 at 5/25/22 6:17 PM:
[
https://issues.apache.org/jira/browse/KAFKA-13884?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17542168#comment-17542168
]
lqjacklee commented on KAFKA-13884:
---
[~jagsancio] I plan add observer.refresh.time.ms
[
https://issues.apache.org/jira/browse/KAFKA-13888?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17542111#comment-17542111
]
lqjacklee commented on KAFKA-13888:
---
[~Niket Goel] https://github.com/apache/kafka/pul
[
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 DescribeQuorumResp
[
https://issues.apache.org/jira/browse/KAFKA-13888?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17541841#comment-17541841
]
lqjacklee commented on KAFKA-13888:
---
[~Niket Goel] thanks your reply. I will continue
[
https://issues.apache.org/jira/browse/KAFKA-13888?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17540910#comment-17540910
]
lqjacklee commented on KAFKA-13888:
---
[~Niket Goel] can I take the task ? I am working
[
https://issues.apache.org/jira/browse/KAFKA-13888?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17539465#comment-17539465
]
lqjacklee commented on KAFKA-13888:
---
[~Niket Goel] for the field ‘LastCaughtUpTimestam
[
https://issues.apache.org/jira/browse/KAFKA-13864?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17538542#comment-17538542
]
lqjacklee commented on KAFKA-13864:
---
[~frosiere] sorry late to reply , I have just res
[
https://issues.apache.org/jira/browse/KAFKA-13888?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17534847#comment-17534847
]
lqjacklee commented on KAFKA-13888:
---
{code:java}
// code placeholder
{code}
[~Niket Go
[
https://issues.apache.org/jira/browse/KAFKA-13888?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17534847#comment-17534847
]
lqjacklee edited comment on KAFKA-13888 at 5/11/22 12:06 PM:
-
[
https://issues.apache.org/jira/browse/KAFKA-13886?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17533200#comment-17533200
]
lqjacklee commented on KAFKA-13886:
---
https://github.com/apache/kafka/pull/12133
> imp
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: Ka
[
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 KafkaProducer
[
https://issues.apache.org/jira/browse/KAFKA-13864?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17532216#comment-17532216
]
lqjacklee commented on KAFKA-13864:
---
[~frosiere] [~cadonna] please help review the c
[
https://issues.apache.org/jira/browse/KAFKA-13864?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17530689#comment-17530689
]
lqjacklee commented on KAFKA-13864:
---
[~frosiere] [~cadonna] please help review the pa
[
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 KafkaC
[
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 which
[
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 which
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
Issue
[
https://issues.apache.org/jira/browse/KAFKA-7988?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17529449#comment-17529449
]
lqjacklee commented on KAFKA-7988:
--
why exist the same thread name ?
{code:java}
Invali
[
https://issues.apache.org/jira/browse/KAFKA-13745?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17529252#comment-17529252
]
lqjacklee commented on KAFKA-13745:
---
[~sagarrao] I want to add the log warning to catc
[
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 name
[
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 partitio
[
https://issues.apache.org/jira/browse/KAFKA-10827?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17263926#comment-17263926
]
lqjacklee commented on KAFKA-10827:
---
[~jaebinyo] I have create the test case to replay
[
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 partitio
[
https://issues.apache.org/jira/browse/KAFKA-10827?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17246250#comment-17246250
]
lqjacklee commented on KAFKA-10827:
---
[~jaebinyo] If we are in the bad network environm
[
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 partitio
[
https://issues.apache.org/jira/browse/KAFKA-10824?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=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 availab
[
https://issues.apache.org/jira/browse/KAFKA-10824?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17246238#comment-17246238
]
lqjacklee commented on KAFKA-10824:
---
[~mohammadabboud] I can infer based on
*
[
https://issues.apache.org/jira/browse/KAFKA-10793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17241985#comment-17241985
]
lqjacklee commented on KAFKA-10793:
---
[~ableegoldman] I want to check whether the heart
[
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&focusedCommentId=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&focusedCommentId=17237888#comment-17237888
]
lqjacklee commented on KAFKA-10753:
---
[~dengziming] From my opinion , in the task we sh
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: Bug
[
https://issues.apache.org/jira/browse/KAFKA-10753?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17237792#comment-17237792
]
lqjacklee commented on KAFKA-10753:
---
[~17hao] I have uploaded the patch to cover the c
[
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&focusedCommentId=17237054#comment-17237054
]
lqjacklee commented on KAFKA-10753:
---
[~dengziming] should we create another jira to tr
[
https://issues.apache.org/jira/browse/KAFKA-10753?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17236189#comment-17236189
]
lqjacklee commented on KAFKA-10753:
---
{code:java}
public void reset(long timeoutMs) {
[
https://issues.apache.org/jira/browse/KAFKA-10753?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17235946#comment-17235946
]
lqjacklee commented on KAFKA-10753:
---
[~showuon] org.apache.kafka.common.utils.Time nee
[
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&focusedCommentId=17233300#comment-17233300
]
lqjacklee commented on KAFKA-10726:
---
If you are seeing excessive pauses during garbage
[
https://issues.apache.org/jira/browse/KAFKA-10666?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17233277#comment-17233277
]
lqjacklee commented on KAFKA-10666:
---
[~pfjason] Does https://issues.apache.org/jira/br
[
https://issues.apache.org/jira/browse/KAFKA-10713?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17231322#comment-17231322
]
lqjacklee commented on KAFKA-10713:
---
the bootstrap.servers should configured with Spli
[
https://issues.apache.org/jira/browse/KAFKA-10694?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17229630#comment-17229630
]
lqjacklee commented on KAFKA-10694:
---
[~jagsancio] thanks a lot .
> Implement zero cop
[
https://issues.apache.org/jira/browse/KAFKA-10694?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17229029#comment-17229029
]
lqjacklee commented on KAFKA-10694:
---
[~jagsancio] Can I take the task?
> Implement z
[
https://issues.apache.org/jira/browse/KAFKA-10666?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17224605#comment-17224605
]
lqjacklee commented on KAFKA-10666:
---
[~pfjason] checked the code. we just load the con
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: Improvem
55 matches
Mail list logo
