[jira] [Commented] (KAFKA-15160) Message bytes duplication in Kafka headers when compression is enabled

[ https://issues.apache.org/jira/browse/KAFKA-15160?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17764956#comment-17764956 ] Phuc Hong Tran commented on KAFKA-15160: [~vikashmishra0808] How did you setup ConsumerRecord

[jira] [Comment Edited] (KAFKA-15160) Message bytes duplication in Kafka headers when compression is enabled

[ https://issues.apache.org/jira/browse/KAFKA-15160?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17764956#comment-17764956 ] Phuc Hong Tran edited comment on KAFKA-15160 at 9/14/23 3:32 AM: -

[jira] [Assigned] (KAFKA-15341) Enabling TS for a topic during rolling restart causes problems

[ https://issues.apache.org/jira/browse/KAFKA-15341?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Phuc Hong Tran reassigned KAFKA-15341: -- Assignee: Phuc Hong Tran > Enabling TS for a topic during rolling restart causes

[jira] [Assigned] (KAFKA-15432) RLM Stop partitions should not be invoked for non-tiered storage topics

[ https://issues.apache.org/jira/browse/KAFKA-15432?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Phuc Hong Tran reassigned KAFKA-15432: -- Assignee: Phuc Hong Tran > RLM Stop partitions should not be invoked for non-tiered

[jira] [Commented] (KAFKA-15160) Message bytes duplication in Kafka headers when compression is enabled

[ https://issues.apache.org/jira/browse/KAFKA-15160?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17764677#comment-17764677 ] Phuc Hong Tran commented on KAFKA-15160: [~vikashmishra0808] Sorry for the delay, I'm

[jira] [Assigned] (KAFKA-15341) Enabling TS for a topic during rolling restart causes problems

[ https://issues.apache.org/jira/browse/KAFKA-15341?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Phuc Hong Tran reassigned KAFKA-15341: -- Assignee: (was: Phuc Hong Tran) > Enabling TS for a topic during rolling restart

[jira] [Assigned] (KAFKA-15432) RLM Stop partitions should not be invoked for non-tiered storage topics

[ https://issues.apache.org/jira/browse/KAFKA-15432?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Phuc Hong Tran reassigned KAFKA-15432: -- Assignee: (was: Phuc Hong Tran) > RLM Stop partitions should not be invoked for

[jira] [Commented] (KAFKA-15160) Message bytes duplication in Kafka headers when compression is enabled

[ https://issues.apache.org/jira/browse/KAFKA-15160?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17778327#comment-17778327 ] Phuc Hong Tran commented on KAFKA-15160: [~vikashmishra0808] I wasn’t able to confirm the issue,

[jira] [Assigned] (KAFKA-15341) Enabling TS for a topic during rolling restart causes problems

[ https://issues.apache.org/jira/browse/KAFKA-15341?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Phuc Hong Tran reassigned KAFKA-15341: -- Assignee: Phuc Hong Tran > Enabling TS for a topic during rolling restart causes

[jira] [Assigned] (KAFKA-15152) Fix incorrect format specifiers when formatting string

[ https://issues.apache.org/jira/browse/KAFKA-15152?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Phuc Hong Tran reassigned KAFKA-15152: -- Assignee: Phuc Hong Tran > Fix incorrect format specifiers when formatting string >

[jira] [Comment Edited] (KAFKA-15152) Fix incorrect format specifiers when formatting string

[ https://issues.apache.org/jira/browse/KAFKA-15152?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17741814#comment-17741814 ] Phuc Hong Tran edited comment on KAFKA-15152 at 7/11/23 2:30 AM: - Hi

[jira] [Commented] (KAFKA-15152) Fix incorrect format specifiers when formatting string

[ https://issues.apache.org/jira/browse/KAFKA-15152?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17741814#comment-17741814 ] Phuc Hong Tran commented on KAFKA-15152: Hi [~divijvaidya], can I have this one assign to me?

[jira] [Commented] (KAFKA-15152) Fix incorrect format specifiers when formatting string

[ https://issues.apache.org/jira/browse/KAFKA-15152?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17744017#comment-17744017 ] Phuc Hong Tran commented on KAFKA-15152: [~divijvaidya] Can you review my pr? Thanks > Fix

[jira] [Assigned] (KAFKA-15160) Message bytes duplication in Kafka headers when compression is enabled

[ https://issues.apache.org/jira/browse/KAFKA-15160?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Phuc Hong Tran reassigned KAFKA-15160: -- Assignee: Phuc Hong Tran > Message bytes duplication in Kafka headers when

[jira] [Commented] (KAFKA-16160) AsyncKafkaConsumer is trying to connect to a disconnected node in a tight loop

[ https://issues.apache.org/jira/browse/KAFKA-16160?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17819003#comment-17819003 ] Phuc Hong Tran commented on KAFKA-16160: For this one, I do need some helps. >

[jira] [Commented] (KAFKA-16160) AsyncKafkaConsumer is trying to connect to a disconnected node in a tight loop

[ https://issues.apache.org/jira/browse/KAFKA-16160?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17819005#comment-17819005 ] Phuc Hong Tran commented on KAFKA-16160: [~kirktrue] I was not able to reproduce this scenario

[jira] [Commented] (KAFKA-15538) Client support for java regex based subscription

[ https://issues.apache.org/jira/browse/KAFKA-15538?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17819008#comment-17819008 ] Phuc Hong Tran commented on KAFKA-15538: I can put up a pull request for this ticket by this

[jira] [Comment Edited] (KAFKA-16160) AsyncKafkaConsumer is trying to connect to a disconnected node in a tight loop

[ https://issues.apache.org/jira/browse/KAFKA-16160?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17819009#comment-17819009 ] Phuc Hong Tran edited comment on KAFKA-16160 at 2/20/24 11:15 PM: -- Also

[jira] [Commented] (KAFKA-16160) AsyncKafkaConsumer is trying to connect to a disconnected node in a tight loop

[ https://issues.apache.org/jira/browse/KAFKA-16160?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17819009#comment-17819009 ] Phuc Hong Tran commented on KAFKA-16160: Also after some findings, I’m thinking that this one is

[jira] [Comment Edited] (KAFKA-15538) Client support for java regex based subscription

[ https://issues.apache.org/jira/browse/KAFKA-15538?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17819008#comment-17819008 ] Phuc Hong Tran edited comment on KAFKA-15538 at 2/21/24 4:43 PM: - I can

[jira] [Commented] (KAFKA-15538) Client support for java regex based subscription

[ https://issues.apache.org/jira/browse/KAFKA-15538?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17815041#comment-17815041 ] Phuc Hong Tran commented on KAFKA-15538: [~lianetm] I think instead of closing this ticket we

[jira] [Commented] (KAFKA-15341) Enabling TS for a topic during rolling restart causes problems

[ https://issues.apache.org/jira/browse/KAFKA-15341?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17800124#comment-17800124 ] Phuc Hong Tran commented on KAFKA-15341: hi [~divijvaidya], if you have time, can you help me

[jira] [Assigned] (KAFKA-15558) Determine if Timer should be used elsewhere in PrototypeAsyncConsumer.updateFetchPositions()

[ https://issues.apache.org/jira/browse/KAFKA-15558?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Phuc Hong Tran reassigned KAFKA-15558: -- Assignee: Phuc Hong Tran > Determine if Timer should be used elsewhere in >

[jira] [Assigned] (KAFKA-16011) Fix PlaintextConsumerTest.testMultiConsumerSessionTimeoutOnClose

[ https://issues.apache.org/jira/browse/KAFKA-16011?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Phuc Hong Tran reassigned KAFKA-16011: -- Assignee: Phuc Hong Tran > Fix

[jira] [Assigned] (KAFKA-16024) SaslPlaintextConsumerTest#testCoordinatorFailover is flaky

[ https://issues.apache.org/jira/browse/KAFKA-16024?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Phuc Hong Tran reassigned KAFKA-16024: -- Assignee: Phuc Hong Tran > SaslPlaintextConsumerTest#testCoordinatorFailover is

[jira] [Assigned] (KAFKA-16022) AsyncKafkaConsumer sometimes complains "No current assignment for partition {}"

[ https://issues.apache.org/jira/browse/KAFKA-16022?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Phuc Hong Tran reassigned KAFKA-16022: -- Assignee: Phuc Hong Tran > AsyncKafkaConsumer sometimes complains "No current

[jira] [Commented] (KAFKA-15558) Determine if Timer should be used elsewhere in PrototypeAsyncConsumer.updateFetchPositions()

[ https://issues.apache.org/jira/browse/KAFKA-15558?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17800672#comment-17800672 ] Phuc Hong Tran commented on KAFKA-15558: [~kirktrue], please correct me if I'm wrong, but isn't

[jira] [Comment Edited] (KAFKA-15558) Determine if Timer should be used elsewhere in PrototypeAsyncConsumer.updateFetchPositions()

[ https://issues.apache.org/jira/browse/KAFKA-15558?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17800672#comment-17800672 ] Phuc Hong Tran edited comment on KAFKA-15558 at 12/27/23 6:22 AM: --

[jira] [Assigned] (KAFKA-16034) AsyncKafkaConsumer will get Invalid Request error when trying to rejoin on fenced/unknown member Id

[ https://issues.apache.org/jira/browse/KAFKA-16034?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Phuc Hong Tran reassigned KAFKA-16034: -- Assignee: Phuc Hong Tran > AsyncKafkaConsumer will get Invalid Request error when

[jira] [Assigned] (KAFKA-15948) Refactor AsyncKafkaConsumer shutdown

[ https://issues.apache.org/jira/browse/KAFKA-15948?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Phuc Hong Tran reassigned KAFKA-15948: -- Assignee: Phuc Hong Tran > Refactor AsyncKafkaConsumer shutdown >

[jira] [Commented] (KAFKA-15341) Enabling TS for a topic during rolling restart causes problems

[ https://issues.apache.org/jira/browse/KAFKA-15341?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17798760#comment-17798760 ] Phuc Hong Tran commented on KAFKA-15341: Got it. Thanks, [~showuon]  > Enabling TS for a topic

[jira] [Commented] (KAFKA-16034) AsyncKafkaConsumer will get Invalid Request error when trying to rejoin on fenced/unknown member Id

[ https://issues.apache.org/jira/browse/KAFKA-16034?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17801811#comment-17801811 ] Phuc Hong Tran commented on KAFKA-16034: [~pnee], I don't think reset HeartbeatState is enough

[jira] [Assigned] (KAFKA-15682) Ensure internal remote log metadata topic does not expire its segments before deleting user-topic segments

[ https://issues.apache.org/jira/browse/KAFKA-15682?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Phuc Hong Tran reassigned KAFKA-15682: -- Assignee: Phuc Hong Tran > Ensure internal remote log metadata topic does not expire

[jira] [Assigned] (KAFKA-15561) Client support for new SubscriptionPattern based subscription

[ https://issues.apache.org/jira/browse/KAFKA-15561?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Phuc Hong Tran reassigned KAFKA-15561: -- Assignee: Phuc Hong Tran > Client support for new SubscriptionPattern based

[jira] [Commented] (KAFKA-16034) AsyncKafkaConsumer will get Invalid Request error when trying to rejoin on fenced/unknown member Id

[ https://issues.apache.org/jira/browse/KAFKA-16034?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17802013#comment-17802013 ] Phuc Hong Tran commented on KAFKA-16034: [~pnee] PlainTextConsumerTest isn't failing with any

[jira] [Resolved] (KAFKA-16034) AsyncKafkaConsumer will get Invalid Request error when trying to rejoin on fenced/unknown member Id

[ https://issues.apache.org/jira/browse/KAFKA-16034?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Phuc Hong Tran resolved KAFKA-16034. Resolution: Fixed > AsyncKafkaConsumer will get Invalid Request error when trying to

[jira] [Commented] (KAFKA-15867) Should ConsumerNetworkThread wrap the exception and notify the polling thread?

[ https://issues.apache.org/jira/browse/KAFKA-15867?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17802158#comment-17802158 ] Phuc Hong Tran commented on KAFKA-15867: [~pnee] I happened to come across this comment:

[jira] [Commented] (KAFKA-15341) Enabling TS for a topic during rolling restart causes problems

[ https://issues.apache.org/jira/browse/KAFKA-15341?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17803405#comment-17803405 ] Phuc Hong Tran commented on KAFKA-15341: [~divijvaidya], broker feature is just the IBP version,

[jira] [Commented] (KAFKA-15538) Client support for java regex based subscription

[ https://issues.apache.org/jira/browse/KAFKA-15538?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17805326#comment-17805326 ] Phuc Hong Tran commented on KAFKA-15538: I understand, will be more careful when readling ticket

[jira] [Commented] (KAFKA-15561) Client support for new SubscriptionPattern based subscription

[ https://issues.apache.org/jira/browse/KAFKA-15561?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17805327#comment-17805327 ] Phuc Hong Tran commented on KAFKA-15561: I see. I was wondering this since this ticket requires

[jira] [Resolved] (KAFKA-15538) Client support for java regex based subscription

[ https://issues.apache.org/jira/browse/KAFKA-15538?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Phuc Hong Tran resolved KAFKA-15538. Resolution: Fixed > Client support for java regex based subscription >

[jira] [Comment Edited] (KAFKA-15538) Client support for java regex based subscription

[ https://issues.apache.org/jira/browse/KAFKA-15538?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17805393#comment-17805393 ] Phuc Hong Tran edited comment on KAFKA-15538 at 1/11/24 6:51 AM: - Look

[jira] [Reopened] (KAFKA-15538) Client support for java regex based subscription

[ https://issues.apache.org/jira/browse/KAFKA-15538?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Phuc Hong Tran reopened KAFKA-15538: > Client support for java regex based subscription >

[jira] [Commented] (KAFKA-15538) Client support for java regex based subscription

[ https://issues.apache.org/jira/browse/KAFKA-15538?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17805397#comment-17805397 ] Phuc Hong Tran commented on KAFKA-15538: hm nvm let's me double check > Client support for java

[jira] [Commented] (KAFKA-15538) Client support for java regex based subscription

[ https://issues.apache.org/jira/browse/KAFKA-15538?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17805393#comment-17805393 ] Phuc Hong Tran commented on KAFKA-15538: Look like this has already been done in

[jira] [Commented] (KAFKA-15561) Client support for new SubscriptionPattern based subscription

[ https://issues.apache.org/jira/browse/KAFKA-15561?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17805806#comment-17805806 ] Phuc Hong Tran commented on KAFKA-15561: [~lianetm] are the classes that implements ApiMessage

[jira] [Commented] (KAFKA-15561) Client support for new SubscriptionPattern based subscription

[ https://issues.apache.org/jira/browse/KAFKA-15561?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17805883#comment-17805883 ] Phuc Hong Tran commented on KAFKA-15561: I figured those out, so they were auto-gerenated

[jira] [Commented] (KAFKA-15561) Client support for new SubscriptionPattern based subscription

[ https://issues.apache.org/jira/browse/KAFKA-15561?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17805880#comment-17805880 ] Phuc Hong Tran commented on KAFKA-15561: [~lianetm], look like the problem is on my local

[jira] (KAFKA-15561) Client support for new SubscriptionPattern based subscription

[ https://issues.apache.org/jira/browse/KAFKA-15561 ] Phuc Hong Tran deleted comment on KAFKA-15561: was (Author: JIRAUSER301295): [~lianetm], look like the problem is on my local machine. > Client support for new SubscriptionPattern based

[jira] [Commented] (KAFKA-15538) Client support for java regex based subscription

[ https://issues.apache.org/jira/browse/KAFKA-15538?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17806628#comment-17806628 ] Phuc Hong Tran commented on KAFKA-15538: [~lianetm], I have one last question for this ticket,

[jira] [Comment Edited] (KAFKA-15538) Client support for java regex based subscription

[ https://issues.apache.org/jira/browse/KAFKA-15538?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17806622#comment-17806622 ] Phuc Hong Tran edited comment on KAFKA-15538 at 1/15/24 5:13 AM: - This

[jira] [Comment Edited] (KAFKA-15538) Client support for java regex based subscription

[ https://issues.apache.org/jira/browse/KAFKA-15538?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17806622#comment-17806622 ] Phuc Hong Tran edited comment on KAFKA-15538 at 1/15/24 5:08 AM: - This

[jira] [Commented] (KAFKA-15538) Client support for java regex based subscription

[ https://issues.apache.org/jira/browse/KAFKA-15538?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17806622#comment-17806622 ] Phuc Hong Tran commented on KAFKA-15538: This is already implemented. I'm closing this ticket.

[jira] [Comment Edited] (KAFKA-15538) Client support for java regex based subscription

[ https://issues.apache.org/jira/browse/KAFKA-15538?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17806622#comment-17806622 ] Phuc Hong Tran edited comment on KAFKA-15538 at 1/15/24 5:09 AM: - This

[jira] [Resolved] (KAFKA-15538) Client support for java regex based subscription

[ https://issues.apache.org/jira/browse/KAFKA-15538?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Phuc Hong Tran resolved KAFKA-15538. Resolution: Fixed > Client support for java regex based subscription >

[jira] [Commented] (KAFKA-14507) Add ConsumerGroupPrepareAssignment API

[ https://issues.apache.org/jira/browse/KAFKA-14507?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17807006#comment-17807006 ] Phuc Hong Tran commented on KAFKA-14507: sure [~linzihao1999]  > Add

[jira] [Commented] (KAFKA-14508) Add ConsumerGroupInstallAssignment API

[ https://issues.apache.org/jira/browse/KAFKA-14508?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17807005#comment-17807005 ] Phuc Hong Tran commented on KAFKA-14508: thanks [~alexanderaghili]  > Add

[jira] [Assigned] (KAFKA-14507) Add ConsumerGroupPrepareAssignment API

[ https://issues.apache.org/jira/browse/KAFKA-14507?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Phuc Hong Tran reassigned KAFKA-14507: -- Assignee: Phuc Hong Tran (was: Zihao Lin) > Add ConsumerGroupPrepareAssignment API

[jira] [Assigned] (KAFKA-14508) Add ConsumerGroupInstallAssignment API

[ https://issues.apache.org/jira/browse/KAFKA-14508?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Phuc Hong Tran reassigned KAFKA-14508: -- Assignee: Phuc Hong Tran > Add ConsumerGroupInstallAssignment API >

[jira] [Resolved] (KAFKA-15809) Update broker's metadata schema to include TS enable status

[ https://issues.apache.org/jira/browse/KAFKA-15809?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Phuc Hong Tran resolved KAFKA-15809. Resolution: Won't Fix > Update broker's metadata schema to include TS enable status >

[jira] [Assigned] (KAFKA-15341) Enabling TS for a topic during rolling restart causes problems

[ https://issues.apache.org/jira/browse/KAFKA-15341?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Phuc Hong Tran reassigned KAFKA-15341: -- Assignee: (was: Phuc Hong Tran) > Enabling TS for a topic during rolling restart

[jira] [Assigned] (KAFKA-15682) Ensure internal remote log metadata topic does not expire its segments before deleting user-topic segments

[ https://issues.apache.org/jira/browse/KAFKA-15682?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Phuc Hong Tran reassigned KAFKA-15682: -- Assignee: (was: Phuc Hong Tran) > Ensure internal remote log metadata topic does

[jira] [Commented] (KAFKA-15538) Client support for java regex based subscription

[ https://issues.apache.org/jira/browse/KAFKA-15538?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17807487#comment-17807487 ] Phuc Hong Tran commented on KAFKA-15538: [~lianetm] thanks for the comments. Just to clarify

[jira] [Commented] (KAFKA-15538) Client support for java regex based subscription

[ https://issues.apache.org/jira/browse/KAFKA-15538?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17807937#comment-17807937 ] Phuc Hong Tran commented on KAFKA-15538: I understand now. Thanks [~lianetm]  > Client support

[jira] [Assigned] (KAFKA-16160) AsyncKafkaConsumer is trying to connect to a disconnected node in a tight loop

[ https://issues.apache.org/jira/browse/KAFKA-16160?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Phuc Hong Tran reassigned KAFKA-16160: -- Assignee: Phuc Hong Tran > AsyncKafkaConsumer is trying to connect to a disconnected

[jira] [Commented] (KAFKA-15538) Client support for java regex based subscription

[ https://issues.apache.org/jira/browse/KAFKA-15538?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17804699#comment-17804699 ] Phuc Hong Tran commented on KAFKA-15538: [~lianetm], this is a duplicate of KAFKA-15561 >

[jira] [Commented] (KAFKA-14507) Add ConsumerGroupPrepareAssignment API

[ https://issues.apache.org/jira/browse/KAFKA-14507?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17804700#comment-17804700 ] Phuc Hong Tran commented on KAFKA-14507: Hi [~linzihao1999], are you still working on this? >

[jira] [Commented] (KAFKA-14508) Add ConsumerGroupInstallAssignment API

[ https://issues.apache.org/jira/browse/KAFKA-14508?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17804698#comment-17804698 ] Phuc Hong Tran commented on KAFKA-14508: [~alexanderaghili] are you still working on this? May I

[jira] [Assigned] (KAFKA-15538) Client support for java regex based subscription

[ https://issues.apache.org/jira/browse/KAFKA-15538?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Phuc Hong Tran reassigned KAFKA-15538: -- Assignee: Phuc Hong Tran > Client support for java regex based subscription >

[jira] [Commented] (KAFKA-15561) Client support for new SubscriptionPattern based subscription

[ https://issues.apache.org/jira/browse/KAFKA-15561?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17804103#comment-17804103 ] Phuc Hong Tran commented on KAFKA-15561: Hi [~lianetm], at the end if the document of KIP 848 I

[jira] [Commented] (KAFKA-15682) Ensure internal remote log metadata topic does not expire its segments before deleting user-topic segments

[ https://issues.apache.org/jira/browse/KAFKA-15682?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17803749#comment-17803749 ] Phuc Hong Tran commented on KAFKA-15682: [~ckamal] is the retention rate of

[jira] [Commented] (KAFKA-15558) Determine if Timer should be used elsewhere in PrototypeAsyncConsumer.updateFetchPositions()

[ https://issues.apache.org/jira/browse/KAFKA-15558?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17804348#comment-17804348 ] Phuc Hong Tran commented on KAFKA-15558: [~schofielaj], can you elaborate a bit more about it?

[jira] [Comment Edited] (KAFKA-15558) Determine if Timer should be used elsewhere in PrototypeAsyncConsumer.updateFetchPositions()

[ https://issues.apache.org/jira/browse/KAFKA-15558?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17804348#comment-17804348 ] Phuc Hong Tran edited comment on KAFKA-15558 at 1/8/24 3:45 PM:

[jira] [Commented] (KAFKA-15561) Client support for new SubscriptionPattern based subscription

[ https://issues.apache.org/jira/browse/KAFKA-15561?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17806274#comment-17806274 ] Phuc Hong Tran commented on KAFKA-15561: [~lianetm], I have created a pull request for this

[jira] [Commented] (KAFKA-15561) Client support for new SubscriptionPattern based subscription

[ https://issues.apache.org/jira/browse/KAFKA-15561?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17806275#comment-17806275 ] Phuc Hong Tran commented on KAFKA-15561: thanks for confirming [~schofielaj]  > Client support

[jira] [Commented] (KAFKA-16011) Fix PlaintextConsumerTest.testMultiConsumerSessionTimeoutOnClose

[ https://issues.apache.org/jira/browse/KAFKA-16011?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17800979#comment-17800979 ] Phuc Hong Tran commented on KAFKA-16011: I think [~pnee] already fixed this in

[jira] [Resolved] (KAFKA-16011) Fix PlaintextConsumerTest.testMultiConsumerSessionTimeoutOnClose

[ https://issues.apache.org/jira/browse/KAFKA-16011?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Phuc Hong Tran resolved KAFKA-16011. Resolution: Fixed > Fix PlaintextConsumerTest.testMultiConsumerSessionTimeoutOnClose >

[jira] [Assigned] (KAFKA-15867) Should ConsumerNetworkThread wrap the exception and notify the polling thread?

[ https://issues.apache.org/jira/browse/KAFKA-15867?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Phuc Hong Tran reassigned KAFKA-15867: -- Assignee: Phuc Hong Tran > Should ConsumerNetworkThread wrap the exception and

[jira] [Comment Edited] (KAFKA-15558) Determine if Timer should be used elsewhere in PrototypeAsyncConsumer.updateFetchPositions()

[ https://issues.apache.org/jira/browse/KAFKA-15558?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17800672#comment-17800672 ] Phuc Hong Tran edited comment on KAFKA-15558 at 12/28/23 12:32 PM: ---

[jira] [Updated] (KAFKA-15809) Update broker's metadata schema to include TS enable status

[ https://issues.apache.org/jira/browse/KAFKA-15809?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Phuc Hong Tran updated KAFKA-15809: --- Summary: Update broker's metadata schema to include TS enable status (was: Updating

[jira] [Commented] (KAFKA-15341) Enabling TS for a topic during rolling restart causes problems

[ https://issues.apache.org/jira/browse/KAFKA-15341?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17789322#comment-17789322 ] Phuc Hong Tran commented on KAFKA-15341: FYI, I'm writting my findings here so I don't forget

[jira] [Commented] (KAFKA-15556) Remove NetworkClientDelegate methods isUnavailable, maybeThrowAuthFailure, and tryConnect

[ https://issues.apache.org/jira/browse/KAFKA-15556?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17794714#comment-17794714 ] Phuc Hong Tran commented on KAFKA-15556: Nvm, I saw your comments in

[jira] [Comment Edited] (KAFKA-15556) Remove NetworkClientDelegate methods isUnavailable, maybeThrowAuthFailure, and tryConnect

[ https://issues.apache.org/jira/browse/KAFKA-15556?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17793972#comment-17793972 ] Phuc Hong Tran edited comment on KAFKA-15556 at 12/7/23 12:51 AM: --

[jira] [Commented] (KAFKA-15556) Remove NetworkClientDelegate methods isUnavailable, maybeThrowAuthFailure, and tryConnect

[ https://issues.apache.org/jira/browse/KAFKA-15556?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17793972#comment-17793972 ] Phuc Hong Tran commented on KAFKA-15556: There is a duplicated method "nodeUnavailable" which

[jira] [Commented] (KAFKA-15556) Remove NetworkClientDelegate methods isUnavailable, maybeThrowAuthFailure, and tryConnect

[ https://issues.apache.org/jira/browse/KAFKA-15556?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17792819#comment-17792819 ] Phuc Hong Tran commented on KAFKA-15556: Hi [~kirktrue], I only see the method "TryConnect" as a

[jira] [Commented] (KAFKA-16190) Member should send full heartbeat when rejoining

[ https://issues.apache.org/jira/browse/KAFKA-16190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17811703#comment-17811703 ] Phuc Hong Tran commented on KAFKA-16190: also the builder is already checking which fields has

[jira] [Commented] (KAFKA-16190) Member should send full heartbeat when rejoining

[ https://issues.apache.org/jira/browse/KAFKA-16190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17811701#comment-17811701 ] Phuc Hong Tran commented on KAFKA-16190: [~lianetm] can we just pass those fields that need to

[jira] [Commented] (KAFKA-15538) Client support for java regex based subscription

[ https://issues.apache.org/jira/browse/KAFKA-15538?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17814054#comment-17814054 ] Phuc Hong Tran commented on KAFKA-15538: [~lianetm], this ticket has some overlaps with ticket

[jira] [Commented] (KAFKA-16160) AsyncKafkaConsumer is trying to connect to a disconnected node in a tight loop

[ https://issues.apache.org/jira/browse/KAFKA-16160?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17812669#comment-17812669 ] Phuc Hong Tran commented on KAFKA-16160: [~pnee] I think we already have reconnectBackoff for

[jira] [Commented] (KAFKA-16190) Member should send full heartbeat when rejoining

[ https://issues.apache.org/jira/browse/KAFKA-16190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17814698#comment-17814698 ] Phuc Hong Tran commented on KAFKA-16190: [~lianetm] I understand, thanks for the explaination.

[jira] [Comment Edited] (KAFKA-15341) Enabling TS for a topic during rolling restart causes problems

[ https://issues.apache.org/jira/browse/KAFKA-15341?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17786537#comment-17786537 ] Phuc Hong Tran edited comment on KAFKA-15341 at 11/15/23 11:09 PM: ---

[jira] [Comment Edited] (KAFKA-15341) Enabling TS for a topic during rolling restart causes problems

[ https://issues.apache.org/jira/browse/KAFKA-15341?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17786537#comment-17786537 ] Phuc Hong Tran edited comment on KAFKA-15341 at 11/15/23 11:26 PM: ---

[jira] [Commented] (KAFKA-15341) Enabling TS for a topic during rolling restart causes problems

[ https://issues.apache.org/jira/browse/KAFKA-15341?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17786537#comment-17786537 ] Phuc Hong Tran commented on KAFKA-15341: thanks [~divijvaidya] [~showuon] [~satishd]. May anyone

[jira] [Updated] (KAFKA-15809) Updating broker's metadata schema to include TS enable status

[ https://issues.apache.org/jira/browse/KAFKA-15809?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Phuc Hong Tran updated KAFKA-15809: --- Summary: Updating broker's metadata schema to include TS enable status (was: Adding TS to

[jira] [Commented] (KAFKA-15341) Enabling TS for a topic during rolling restart causes problems

[ https://issues.apache.org/jira/browse/KAFKA-15341?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17787499#comment-17787499 ] Phuc Hong Tran commented on KAFKA-15341: [~showuon] [~satish.duggana] I’m trying to add remote

[jira] [Commented] (KAFKA-15341) Enabling TS for a topic during rolling restart causes problems

[ https://issues.apache.org/jira/browse/KAFKA-15341?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17787595#comment-17787595 ] Phuc Hong Tran commented on KAFKA-15341: [~showuon] [~satish.duggana], just to clarify, the

[jira] [Commented] (KAFKA-15341) Enabling TS for a topic during rolling restart causes problems

[ https://issues.apache.org/jira/browse/KAFKA-15341?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17787790#comment-17787790 ] Phuc Hong Tran commented on KAFKA-15341: Hi [~ckamal], I have a question about

[jira] [Assigned] (KAFKA-15556) Remove NetworkClientDelegate methods isUnavailable, maybeThrowAuthFailure, and tryConnect

[ https://issues.apache.org/jira/browse/KAFKA-15556?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Phuc Hong Tran reassigned KAFKA-15556: -- Assignee: Phuc Hong Tran > Remove NetworkClientDelegate methods isUnavailable,

[jira] [Commented] (KAFKA-15809) Adding TS to broker's features list and updating broker's metadata schema to include TS enable status

[ https://issues.apache.org/jira/browse/KAFKA-15809?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17786204#comment-17786204 ] Phuc Hong Tran commented on KAFKA-15809: Nvm I got the answer > Adding TS to broker's features

[jira] [Comment Edited] (KAFKA-15341) Enabling TS for a topic during rolling restart causes problems

[ https://issues.apache.org/jira/browse/KAFKA-15341?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17785136#comment-17785136 ] Phuc Hong Tran edited comment on KAFKA-15341 at 11/12/23 9:49 AM: --

  1   2   >