[jira] [Resolved] (KAFKA-15472) Kraft broker does not seem to support sasl/scram authentication

[ https://issues.apache.org/jira/browse/KAFKA-15472?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] RivenSun resolved KAFKA-15472. -- Fix Version/s: 3.5.0 Resolution: Fixed > Kraft broker does not seem to support sasl/scram

[jira] [Commented] (KAFKA-15472) Kraft broker does not seem to support sasl/scram authentication

[ https://issues.apache.org/jira/browse/KAFKA-15472?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17766277#comment-17766277 ] RivenSun commented on KAFKA-15472: -- close this ticket... I found KAFKA-14084 at

[jira] [Created] (KAFKA-15472) Kraft broker does not seem to support sasl/scram authentication

RivenSun created KAFKA-15472: Summary: Kraft broker does not seem to support sasl/scram authentication Key: KAFKA-15472 URL: https://issues.apache.org/jira/browse/KAFKA-15472 Project: Kafka

[jira] [Commented] (KAFKA-15185) Consumers using the latest strategy may lose data after the topic adds partitions

[ https://issues.apache.org/jira/browse/KAFKA-15185?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17742990#comment-17742990 ] RivenSun commented on KAFKA-15185: -- Thanks > Consumers using the latest strategy may lose data after

[jira] [Updated] (KAFKA-15185) Consumers using the latest strategy may lose data after the topic adds partitions

[ https://issues.apache.org/jira/browse/KAFKA-15185?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] RivenSun updated KAFKA-15185: - Description: h2. condition: 1. Business topic adds partition 2. The configuration metadata.max.age.ms

[jira] [Commented] (KAFKA-15185) Consumers using the latest strategy may lose data after the topic adds partitions

[ https://issues.apache.org/jira/browse/KAFKA-15185?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17742737#comment-17742737 ] RivenSun commented on KAFKA-15185: -- Hi [~showuon]  [~guozhang]  can you give any suggestion? Thanks.  

[jira] [Created] (KAFKA-15185) Consumers using the latest strategy may lose data after the topic adds partitions

RivenSun created KAFKA-15185: Summary: Consumers using the latest strategy may lose data after the topic adds partitions Key: KAFKA-15185 URL: https://issues.apache.org/jira/browse/KAFKA-15185 Project:

[jira] [Resolved] (KAFKA-13771) Support to explicitly delete delegationTokens that have expired but have not been automatically cleaned up

[ https://issues.apache.org/jira/browse/KAFKA-13771?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] RivenSun resolved KAFKA-13771. -- Resolution: Resolved > Support to explicitly delete delegationTokens that have expired but have not

[jira] [Commented] (KAFKA-13771) Support to explicitly delete delegationTokens that have expired but have not been automatically cleaned up

[ https://issues.apache.org/jira/browse/KAFKA-13771?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17694399#comment-17694399 ] RivenSun commented on KAFKA-13771: -- [~showuon]  Thanks a lot! > Support to explicitly delete

[jira] [Commented] (KAFKA-13771) Support to explicitly delete delegationTokens that have expired but have not been automatically cleaned up

[ https://issues.apache.org/jira/browse/KAFKA-13771?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17694380#comment-17694380 ] RivenSun commented on KAFKA-13771: -- Hi [~showuon] , PR is merged. could you help change this Jira

[jira] [Assigned] (KAFKA-13771) Support to explicitly delete delegationTokens that have expired but have not been automatically cleaned up

[ https://issues.apache.org/jira/browse/KAFKA-13771?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] RivenSun reassigned KAFKA-13771: Assignee: RivenSun > Support to explicitly delete delegationTokens that have expired but have

[jira] [Commented] (KAFKA-14729) The kafakConsumer pollForFetches(timer) method takes up a lot of cpu due to the abnormal exit of the heartbeat thread

[ https://issues.apache.org/jira/browse/KAFKA-14729?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17690231#comment-17690231 ] RivenSun commented on KAFKA-14729: -- In fact, this is due to the abnormal code of the business side,

[jira] [Updated] (KAFKA-14729) The kafakConsumer pollForFetches(timer) method takes up a lot of cpu due to the abnormal exit of the heartbeat thread

[ https://issues.apache.org/jira/browse/KAFKA-14729?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] RivenSun updated KAFKA-14729: - Description: h2. case situation: 1. The business program occupies a large amount of memory, causing

[jira] [Comment Edited] (KAFKA-14729) The kafakConsumer pollForFetches(timer) method takes up a lot of cpu due to the abnormal exit of the heartbeat thread

[ https://issues.apache.org/jira/browse/KAFKA-14729?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17690166#comment-17690166 ] RivenSun edited comment on KAFKA-14729 at 2/17/23 6:06 AM: --- 1. After careful

[jira] [Commented] (KAFKA-14729) The kafakConsumer pollForFetches(timer) method takes up a lot of cpu due to the abnormal exit of the heartbeat thread

[ https://issues.apache.org/jira/browse/KAFKA-14729?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17690166#comment-17690166 ] RivenSun commented on KAFKA-14729: -- 1. After careful consideration, in the case of KafkaConsumer's

[jira] [Commented] (KAFKA-14729) The kafakConsumer pollForFetches(timer) method takes up a lot of cpu due to the abnormal exit of the heartbeat thread

[ https://issues.apache.org/jira/browse/KAFKA-14729?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17690151#comment-17690151 ] RivenSun commented on KAFKA-14729: -- Hi [~guozhang]   , [~showuon] Could you give some suggestions for

[jira] [Updated] (KAFKA-14729) The kafakConsumer pollForFetches(timer) method takes up a lot of cpu due to the abnormal exit of the heartbeat thread

[ https://issues.apache.org/jira/browse/KAFKA-14729?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] RivenSun updated KAFKA-14729: - Affects Version/s: (was: 3.3.2) > The kafakConsumer pollForFetches(timer) method takes up a lot of

[jira] [Updated] (KAFKA-14729) The kafakConsumer pollForFetches(timer) method takes up a lot of cpu due to the abnormal exit of the heartbeat thread

[ https://issues.apache.org/jira/browse/KAFKA-14729?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] RivenSun updated KAFKA-14729: - Description: h2. case situation: 1. The business program occupies a large amount of memory, causing

[jira] [Created] (KAFKA-14729) The kafakConsumer pollForFetches(timer) method takes up a lot of cpu due to the abnormal exit of the heartbeat thread

RivenSun created KAFKA-14729: Summary: The kafakConsumer pollForFetches(timer) method takes up a lot of cpu due to the abnormal exit of the heartbeat thread Key: KAFKA-14729 URL:

[jira] [Updated] (KAFKA-13310) KafkaConsumer cannot jump out of the poll method, and the consumer is blocked in the ConsumerCoordinator method maybeAutoCommitOffsetsSync(Timer timer). Cpu and traffic

[ https://issues.apache.org/jira/browse/KAFKA-13310?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] RivenSun updated KAFKA-13310: - Summary: KafkaConsumer cannot jump out of the poll method, and the consumer is blocked in the

[jira] [Comment Edited] (KAFKA-13890) Improve documentation of ssl.keystore.type and ssl.truststore.type

[ https://issues.apache.org/jira/browse/KAFKA-13890?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17534142#comment-17534142 ] RivenSun edited comment on KAFKA-13890 at 5/10/22 5:06 AM: --- I'm not sure if

[jira] [Commented] (KAFKA-13890) Improve documentation of ssl.keystore.type and ssl.truststore.type

[ https://issues.apache.org/jira/browse/KAFKA-13890?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17534142#comment-17534142 ] RivenSun commented on KAFKA-13890: -- I'm not sure if it's appropriate to add a validator here. I just

[jira] [Commented] (KAFKA-13890) Improve documentation of ssl.keystore.type and ssl.truststore.type

[ https://issues.apache.org/jira/browse/KAFKA-13890?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17534115#comment-17534115 ] RivenSun commented on KAFKA-13890: -- Hi [~guozhang]  , [~showuon] Could you give some suggestions for

[jira] [Created] (KAFKA-13890) Improve documentation of ssl.keystore.type and ssl.truststore.type

RivenSun created KAFKA-13890: Summary: Improve documentation of ssl.keystore.type and ssl.truststore.type Key: KAFKA-13890 URL: https://issues.apache.org/jira/browse/KAFKA-13890 Project: Kafka

[jira] [Commented] (KAFKA-13857) The listOffsets method of KafkaAdminClient should support returning logEndOffset of topicPartition

[ https://issues.apache.org/jira/browse/KAFKA-13857?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17531003#comment-17531003 ] RivenSun commented on KAFKA-13857: -- [~guozhang] Thank you for your reply and approval. I don't have a

[jira] [Commented] (KAFKA-13857) The listOffsets method of KafkaAdminClient should support returning logEndOffset of topicPartition

[ https://issues.apache.org/jira/browse/KAFKA-13857?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17529173#comment-17529173 ] RivenSun commented on KAFKA-13857: -- [~guozhang]  When I count the current number of messages for each

[jira] [Commented] (KAFKA-13857) The listOffsets method of KafkaAdminClient should support returning logEndOffset of topicPartition

[ https://issues.apache.org/jira/browse/KAFKA-13857?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17529143#comment-17529143 ] RivenSun commented on KAFKA-13857: -- Hi [~guozhang]  Thank you for your reply. As you said, in order to

[jira] [Updated] (KAFKA-13857) The listOffsets method of KafkaAdminClient should support returning logEndOffset of topicPartition

[ https://issues.apache.org/jira/browse/KAFKA-13857?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] RivenSun updated KAFKA-13857: - Description: The server side currently handles the LIST_OFFSETS request process as follows: {code:java}

[jira] [Commented] (KAFKA-13857) The listOffsets method of KafkaAdminClient should support returning logEndOffset of topicPartition

[ https://issues.apache.org/jira/browse/KAFKA-13857?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17528170#comment-17528170 ] RivenSun commented on KAFKA-13857: -- Hi [~guozhang]  [~showuon] Could you give some suggestions for this

[jira] [Updated] (KAFKA-13857) The listOffsets method of KafkaAdminClient should support returning logEndOffset of topicPartition

[ https://issues.apache.org/jira/browse/KAFKA-13857?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] RivenSun updated KAFKA-13857: - Description: The server side currently handles the LIST_OFFSETS request process as follows: {code:java}

[jira] [Created] (KAFKA-13857) The listOffsets method of KafkaAdminClient should support returning logEndOffset of topicPartition

RivenSun created KAFKA-13857: Summary: The listOffsets method of KafkaAdminClient should support returning logEndOffset of topicPartition Key: KAFKA-13857 URL: https://issues.apache.org/jira/browse/KAFKA-13857

[jira] [Resolved] (KAFKA-13398) The caller program will be shut down directly when the execution of Kafka script is abnormal

[ https://issues.apache.org/jira/browse/KAFKA-13398?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] RivenSun resolved KAFKA-13398. -- Resolution: Not A Problem > The caller program will be shut down directly when the execution of Kafka

[jira] [Commented] (KAFKA-13849) All topics whose cleanup policy contains `compact` are not executing deleteLogStartOffsetBreachedSegments as expected

[ https://issues.apache.org/jira/browse/KAFKA-13849?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17526443#comment-17526443 ] RivenSun commented on KAFKA-13849: -- After reading the code carefully, I found that the topic of the

[jira] [Resolved] (KAFKA-13849) All topics whose cleanup policy contains `compact` are not executing deleteLogStartOffsetBreachedSegments as expected

[ https://issues.apache.org/jira/browse/KAFKA-13849?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] RivenSun resolved KAFKA-13849. -- Resolution: Not A Bug > All topics whose cleanup policy contains `compact` are not executing >

[jira] [Commented] (KAFKA-13849) All topics whose cleanup policy contains `compact` are not executing deleteLogStartOffsetBreachedSegments as expected

[ https://issues.apache.org/jira/browse/KAFKA-13849?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17526409#comment-17526409 ] RivenSun commented on KAFKA-13849: -- Hi [~guozhang]  [~hachikuji]  , [~showuon] Could you give some

[jira] [Created] (KAFKA-13849) All topics whose cleanup policy contains `compact` are not executing deleteLogStartOffsetBreachedSegments as expected

RivenSun created KAFKA-13849: Summary: All topics whose cleanup policy contains `compact` are not executing deleteLogStartOffsetBreachedSegments as expected Key: KAFKA-13849 URL:

[jira] [Commented] (KAFKA-13838) Improve the poll method of ConsumerNetworkClient

[ https://issues.apache.org/jira/browse/KAFKA-13838?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17525352#comment-17525352 ] RivenSun commented on KAFKA-13838: -- Hi [~guozhang] Thanks for your review. cc [~hachikuji] , could you

[jira] [Commented] (KAFKA-13838) Improve the poll method of ConsumerNetworkClient

[ https://issues.apache.org/jira/browse/KAFKA-13838?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17524707#comment-17524707 ] RivenSun commented on KAFKA-13838: -- Hi [~guozhang]  [~hachikuji]  , [~showuon] Could you give some

[jira] [Commented] (KAFKA-13838) Improve the poll method of ConsumerNetworkClient

[ https://issues.apache.org/jira/browse/KAFKA-13838?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17524705#comment-17524705 ] RivenSun commented on KAFKA-13838: -- After looking at the code carefully, the comments on the second

[jira] [Created] (KAFKA-13838) Improve the poll method of ConsumerNetworkClient

RivenSun created KAFKA-13838: Summary: Improve the poll method of ConsumerNetworkClient Key: KAFKA-13838 URL: https://issues.apache.org/jira/browse/KAFKA-13838 Project: Kafka Issue Type:

[jira] [Commented] (KAFKA-13799) Improve documentation for Kafka zero-copy

[ https://issues.apache.org/jira/browse/KAFKA-13799?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17523960#comment-17523960 ] RivenSun commented on KAFKA-13799: -- Hi [~guozhang]  Could you help to review the PR? Thanks. > Improve

[jira] [Comment Edited] (KAFKA-13799) Improve documentation for Kafka zero-copy

[ https://issues.apache.org/jira/browse/KAFKA-13799?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17522604#comment-17522604 ] RivenSun edited comment on KAFKA-13799 at 4/15/22 1:35 AM: --- [~guozhang] 

[jira] [Comment Edited] (KAFKA-13799) Improve documentation for Kafka zero-copy

[ https://issues.apache.org/jira/browse/KAFKA-13799?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17522604#comment-17522604 ] RivenSun edited comment on KAFKA-13799 at 4/15/22 1:35 AM: --- [~guozhang] 

[jira] [Commented] (KAFKA-13799) Improve documentation for Kafka zero-copy

[ https://issues.apache.org/jira/browse/KAFKA-13799?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17522604#comment-17522604 ] RivenSun commented on KAFKA-13799: -- [~guozhang]  Thanks for your reply. Later  I will create a minor

[jira] [Commented] (KAFKA-13829) The function of max.in.flight.requests.per.connection parameter does not work, it conflicts with the underlying NIO sending data

[ https://issues.apache.org/jira/browse/KAFKA-13829?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17522282#comment-17522282 ] RivenSun commented on KAFKA-13829: -- > we are saying that we can send the subsequent request without

[jira] [Commented] (KAFKA-13829) The function of max.in.flight.requests.per.connection parameter does not work, it conflicts with the underlying NIO sending data

[ https://issues.apache.org/jira/browse/KAFKA-13829?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17522204#comment-17522204 ] RivenSun commented on KAFKA-13829: -- Thanks for the suggestion, luke Later I will try to create a PR and

[jira] [Commented] (KAFKA-13829) The function of max.in.flight.requests.per.connection parameter does not work, it conflicts with the underlying NIO sending data

[ https://issues.apache.org/jira/browse/KAFKA-13829?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17522187#comment-17522187 ] RivenSun commented on KAFKA-13829: -- Hi [~showuon] Thanks for your reply. The testCase

[jira] [Updated] (KAFKA-13829) The function of max.in.flight.requests.per.connection parameter does not work, it conflicts with the underlying NIO sending data

[ https://issues.apache.org/jira/browse/KAFKA-13829?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] RivenSun updated KAFKA-13829: - Issue Type: Improvement (was: Bug) > The function of max.in.flight.requests.per.connection parameter

[jira] [Commented] (KAFKA-13829) The function of max.in.flight.requests.per.connection parameter does not work, it conflicts with the underlying NIO sending data

[ https://issues.apache.org/jira/browse/KAFKA-13829?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17522185#comment-17522185 ] RivenSun commented on KAFKA-13829: -- Fix the semantics of this jira title. The efficacy of

[jira] [Commented] (KAFKA-13829) The function of max.in.flight.requests.per.connection parameter does not work, it conflicts with the underlying NIO sending data

[ https://issues.apache.org/jira/browse/KAFKA-13829?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17522136#comment-17522136 ] RivenSun commented on KAFKA-13829: -- Hi [~guozhang] [~showuon] and [~hachikuji]  Could you give some

[jira] [Updated] (KAFKA-13829) The function of max.in.flight.requests.per.connection parameter does not work, it conflicts with the underlying NIO sending data

[ https://issues.apache.org/jira/browse/KAFKA-13829?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] RivenSun updated KAFKA-13829: - Description: Due to the implementation mechanism of the `OP_WRITE` event of Kafka's underlying NIO,

[jira] [Created] (KAFKA-13829) The function of max.in.flight.requests.per.connection parameter does not work, it conflicts with the underlying NIO sending data

RivenSun created KAFKA-13829: Summary: The function of max.in.flight.requests.per.connection parameter does not work, it conflicts with the underlying NIO sending data Key: KAFKA-13829 URL:

[jira] [Commented] (KAFKA-13793) Add validators for serialization and deserialization related configuration

[ https://issues.apache.org/jira/browse/KAFKA-13793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17520273#comment-17520273 ] RivenSun commented on KAFKA-13793: -- Hi [~showuon]  Could you help review the KIP? Thanks a lot. > Add

[jira] [Commented] (KAFKA-13814) Improve documentation of KafkaConsumer's group.id parameter

[ https://issues.apache.org/jira/browse/KAFKA-13814?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17520057#comment-17520057 ] RivenSun commented on KAFKA-13814: -- Hi [~guozhang]  [~dajac] , [~showuon] Could you give some

[jira] [Created] (KAFKA-13814) Improve documentation of KafkaConsumer's group.id parameter

RivenSun created KAFKA-13814: Summary: Improve documentation of KafkaConsumer's group.id parameter Key: KAFKA-13814 URL: https://issues.apache.org/jira/browse/KAFKA-13814 Project: Kafka Issue

[jira] [Commented] (KAFKA-13793) Add validators for serialization and deserialization related configuration

[ https://issues.apache.org/jira/browse/KAFKA-13793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17519441#comment-17519441 ] RivenSun commented on KAFKA-13793: -- Hi [~showuon]  I created a KIP, please help to review it. 

[jira] [Commented] (KAFKA-13793) Add validators for serialization and deserialization related configuration

[ https://issues.apache.org/jira/browse/KAFKA-13793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17518732#comment-17518732 ] RivenSun commented on KAFKA-13793: -- Hi [~showuon] , please help review PR-12010. Thanks. > Add

[jira] [Commented] (KAFKA-13793) Add validators for serialization and deserialization related configuration

[ https://issues.apache.org/jira/browse/KAFKA-13793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17518660#comment-17518660 ] RivenSun commented on KAFKA-13793: -- Kafka itself supports five sasl mechanisms, GSSAPI (Kerberos),

[jira] [Comment Edited] (KAFKA-13793) Add validators for serialization and deserialization related configuration

[ https://issues.apache.org/jira/browse/KAFKA-13793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17516472#comment-17516472 ] RivenSun edited comment on KAFKA-13793 at 4/6/22 6:26 AM: -- I combed through all

[jira] [Comment Edited] (KAFKA-13793) Add validators for serialization and deserialization related configuration

[ https://issues.apache.org/jira/browse/KAFKA-13793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17516472#comment-17516472 ] RivenSun edited comment on KAFKA-13793 at 4/6/22 6:26 AM: -- I combed through all

[jira] [Comment Edited] (KAFKA-13793) Add validators for serialization and deserialization related configuration

[ https://issues.apache.org/jira/browse/KAFKA-13793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17516472#comment-17516472 ] RivenSun edited comment on KAFKA-13793 at 4/6/22 6:26 AM: -- I combed through all

[jira] [Commented] (KAFKA-13799) Improve documentation for Kafka zero-copy

[ https://issues.apache.org/jira/browse/KAFKA-13799?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17517772#comment-17517772 ] RivenSun commented on KAFKA-13799: -- Hi [~guozhang]  [~dajac] , [~showuon] Could you give some

[jira] [Commented] (KAFKA-13793) Add validators for serialization and deserialization related configuration

[ https://issues.apache.org/jira/browse/KAFKA-13793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17517770#comment-17517770 ] RivenSun commented on KAFKA-13793: -- Hi [~guozhang]  [~dajac] , [~showuon] Could you give some

[jira] [Comment Edited] (KAFKA-13799) Improve documentation for Kafka zero-copy

[ https://issues.apache.org/jira/browse/KAFKA-13799?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17517382#comment-17517382 ] RivenSun edited comment on KAFKA-13799 at 4/5/22 12:37 PM: --- Hi [~showuon]

[jira] [Commented] (KAFKA-13799) Improve documentation for Kafka zero-copy

[ https://issues.apache.org/jira/browse/KAFKA-13799?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17517382#comment-17517382 ] RivenSun commented on KAFKA-13799: -- Hi [~showuon] [~dengziming] and [~guozhang]  I think we can state

[jira] [Created] (KAFKA-13799) Improve documentation for Kafka zero-copy

RivenSun created KAFKA-13799: Summary: Improve documentation for Kafka zero-copy Key: KAFKA-13799 URL: https://issues.apache.org/jira/browse/KAFKA-13799 Project: Kafka Issue Type: Improvement

[jira] [Commented] (KAFKA-13793) Add validators for serialization and deserialization related configuration

[ https://issues.apache.org/jira/browse/KAFKA-13793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17516823#comment-17516823 ] RivenSun commented on KAFKA-13793: -- Hi [~guozhang]  [~dajac] , [~showuon] Could you give some

[jira] [Comment Edited] (KAFKA-13793) Add validators for serialization and deserialization related configuration

[ https://issues.apache.org/jira/browse/KAFKA-13793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17516472#comment-17516472 ] RivenSun edited comment on KAFKA-13793 at 4/3/22 1:07 PM: -- I combed through all

[jira] [Comment Edited] (KAFKA-13793) Add validators for serialization and deserialization related configuration

[ https://issues.apache.org/jira/browse/KAFKA-13793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17516472#comment-17516472 ] RivenSun edited comment on KAFKA-13793 at 4/3/22 12:20 PM: --- I combed through

[jira] [Comment Edited] (KAFKA-13793) Add validators for serialization and deserialization related configuration

[ https://issues.apache.org/jira/browse/KAFKA-13793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17516472#comment-17516472 ] RivenSun edited comment on KAFKA-13793 at 4/3/22 12:17 PM: --- I combed through

[jira] [Comment Edited] (KAFKA-13793) Add validators for serialization and deserialization related configuration

[ https://issues.apache.org/jira/browse/KAFKA-13793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17516472#comment-17516472 ] RivenSun edited comment on KAFKA-13793 at 4/3/22 12:05 PM: --- I combed through

[jira] [Comment Edited] (KAFKA-13793) Add validators for serialization and deserialization related configuration

[ https://issues.apache.org/jira/browse/KAFKA-13793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17516472#comment-17516472 ] RivenSun edited comment on KAFKA-13793 at 4/3/22 11:58 AM: --- I combed through

[jira] [Comment Edited] (KAFKA-13793) Add validators for serialization and deserialization related configuration

[ https://issues.apache.org/jira/browse/KAFKA-13793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17516472#comment-17516472 ] RivenSun edited comment on KAFKA-13793 at 4/3/22 10:59 AM: --- I combed through

[jira] [Comment Edited] (KAFKA-13793) Add validators for serialization and deserialization related configuration

[ https://issues.apache.org/jira/browse/KAFKA-13793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17516472#comment-17516472 ] RivenSun edited comment on KAFKA-13793 at 4/3/22 8:31 AM: -- I combed through all

[jira] [Commented] (KAFKA-13793) Add validators for serialization and deserialization related configuration

[ https://issues.apache.org/jira/browse/KAFKA-13793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17516472#comment-17516472 ] RivenSun commented on KAFKA-13793: -- I combed through all the configs, and the following configs are

[jira] [Commented] (KAFKA-13793) Add validators for serialization and deserialization related configuration

[ https://issues.apache.org/jira/browse/KAFKA-13793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17516429#comment-17516429 ] RivenSun commented on KAFKA-13793: -- Hi [~guozhang]  [~dajac] [~showuon] Could you give some suggestions

[jira] [Created] (KAFKA-13793) Add validators for serialization and deserialization related configuration

RivenSun created KAFKA-13793: Summary: Add validators for serialization and deserialization related configuration Key: KAFKA-13793 URL: https://issues.apache.org/jira/browse/KAFKA-13793 Project: Kafka

[jira] [Resolved] (KAFKA-13786) Optimized documentation for control.plane.listener.name parameter

[ https://issues.apache.org/jira/browse/KAFKA-13786?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] RivenSun resolved KAFKA-13786. -- Reviewer: Luke Chen Assignee: RivenSun Resolution: Fixed > Optimized documentation for

[jira] [Commented] (KAFKA-13786) Optimized documentation for control.plane.listener.name parameter

[ https://issues.apache.org/jira/browse/KAFKA-13786?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17516427#comment-17516427 ] RivenSun commented on KAFKA-13786: -- Hi [~showuon] You can modify the status of this jira Thanks. >

[jira] [Commented] (KAFKA-13786) Optimized documentation for control.plane.listener.name parameter

[ https://issues.apache.org/jira/browse/KAFKA-13786?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17515650#comment-17515650 ] RivenSun commented on KAFKA-13786: -- Hi [~showuon]  I created PR-11978 for this jira. please help to

[jira] [Commented] (KAFKA-13786) Optimized documentation for control.plane.listener.name parameter

[ https://issues.apache.org/jira/browse/KAFKA-13786?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17515213#comment-17515213 ] RivenSun commented on KAFKA-13786: -- Or we don't revise the sentence. Just add to remind users of our

[jira] [Commented] (KAFKA-13786) Optimized documentation for control.plane.listener.name parameter

[ https://issues.apache.org/jira/browse/KAFKA-13786?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17515211#comment-17515211 ] RivenSun commented on KAFKA-13786: -- Hi [~showuon]  Sorry, I know where the difference in our views

[jira] [Commented] (KAFKA-13786) Optimized documentation for control.plane.listener.name parameter

[ https://issues.apache.org/jira/browse/KAFKA-13786?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17515205#comment-17515205 ] RivenSun commented on KAFKA-13786: -- Hi [~showuon]  You can browse the modification history of the

[jira] [Commented] (KAFKA-13786) Optimized documentation for control.plane.listener.name parameter

[ https://issues.apache.org/jira/browse/KAFKA-13786?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17515138#comment-17515138 ] RivenSun commented on KAFKA-13786: -- Hi [~guozhang]  [~dajac] [~showuon] Could you give some suggestions

[jira] [Created] (KAFKA-13786) Optimized documentation for control.plane.listener.name parameter

RivenSun created KAFKA-13786: Summary: Optimized documentation for control.plane.listener.name parameter Key: KAFKA-13786 URL: https://issues.apache.org/jira/browse/KAFKA-13786 Project: Kafka

[jira] [Commented] (KAFKA-13771) Support to explicitly delete delegationTokens that have expired but have not been automatically cleaned up

[ https://issues.apache.org/jira/browse/KAFKA-13771?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17515035#comment-17515035 ] RivenSun commented on KAFKA-13771: -- Hi [~ijuma]  [~rsivaram] Could you give some suggestions for this

[jira] [Commented] (KAFKA-13757) Improve the annotations of all related methods of DelegationToken in the Admin class

[ https://issues.apache.org/jira/browse/KAFKA-13757?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17515034#comment-17515034 ] RivenSun commented on KAFKA-13757: -- Hi [~dajac]  [~rsivaram] Could you give some suggestions for this

[jira] [Commented] (KAFKA-13751) On the broker side, OAUTHBEARER is not compatible with other SASL mechanisms

[ https://issues.apache.org/jira/browse/KAFKA-13751?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17515032#comment-17515032 ] RivenSun commented on KAFKA-13751: -- Hi [~dajac]  [~ijuma]  Could you give some suggestions for this

[jira] [Commented] (KAFKA-13771) Support to explicitly delete delegationTokens that have expired but have not been automatically cleaned up

[ https://issues.apache.org/jira/browse/KAFKA-13771?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17512177#comment-17512177 ] RivenSun commented on KAFKA-13771: -- Hi [~guozhang] [~dajac]   [~ijuma] Could you give some advice?

[jira] [Created] (KAFKA-13771) Support to explicitly delete delegationTokens that have expired but have not been automatically cleaned up

RivenSun created KAFKA-13771: Summary: Support to explicitly delete delegationTokens that have expired but have not been automatically cleaned up Key: KAFKA-13771 URL:

[jira] [Updated] (KAFKA-13757) Improve the annotations of all related methods of DelegationToken in the Admin class

[ https://issues.apache.org/jira/browse/KAFKA-13757?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] RivenSun updated KAFKA-13757: - Description: DelegationToken is a great and lightweight feature, but when users actually use it, they

[jira] [Commented] (KAFKA-13689) AbstractConfig log print information is incorrect

[ https://issues.apache.org/jira/browse/KAFKA-13689?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17511533#comment-17511533 ] RivenSun commented on KAFKA-13689: -- [~guozhang] Thank you for your reply. I will create a PR(11940) to

[jira] [Comment Edited] (KAFKA-13689) AbstractConfig log print information is incorrect

[ https://issues.apache.org/jira/browse/KAFKA-13689?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17511136#comment-17511136 ] RivenSun edited comment on KAFKA-13689 at 3/23/22, 10:04 AM: - Hi [~guozhang] 

[jira] [Comment Edited] (KAFKA-13689) AbstractConfig log print information is incorrect

[ https://issues.apache.org/jira/browse/KAFKA-13689?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17511136#comment-17511136 ] RivenSun edited comment on KAFKA-13689 at 3/23/22, 10:02 AM: - Hi [~guozhang] 

[jira] [Comment Edited] (KAFKA-13689) AbstractConfig log print information is incorrect

[ https://issues.apache.org/jira/browse/KAFKA-13689?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17511136#comment-17511136 ] RivenSun edited comment on KAFKA-13689 at 3/23/22, 10:01 AM: - Hi [~guozhang] 

[jira] [Commented] (KAFKA-13689) AbstractConfig log print information is incorrect

[ https://issues.apache.org/jira/browse/KAFKA-13689?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17511136#comment-17511136 ] RivenSun commented on KAFKA-13689: -- Hi [~guozhang]  I thought about it carefully, maybe we are thinking

[jira] [Commented] (KAFKA-13757) Improve the annotations of all related methods of DelegationToken in the Admin class

[ https://issues.apache.org/jira/browse/KAFKA-13757?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17510492#comment-17510492 ] RivenSun commented on KAFKA-13757: -- Hi [~omkreddy]  [~guozhang] and  [~showuon]  Could you give some

[jira] [Created] (KAFKA-13757) Improve the annotations of all related methods of DelegationToken in the Admin class

RivenSun created KAFKA-13757: Summary: Improve the annotations of all related methods of DelegationToken in the Admin class Key: KAFKA-13757 URL: https://issues.apache.org/jira/browse/KAFKA-13757

[jira] [Commented] (KAFKA-13689) AbstractConfig log print information is incorrect

[ https://issues.apache.org/jira/browse/KAFKA-13689?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17510244#comment-17510244 ] RivenSun commented on KAFKA-13689: -- Hi [~guozhang]  1. We all agree that users can get all their custom

[jira] [Commented] (KAFKA-13751) On the broker side, OAUTHBEARER is not compatible with other SASL mechanisms

[ https://issues.apache.org/jira/browse/KAFKA-13751?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17510185#comment-17510185 ] RivenSun commented on KAFKA-13751: -- Hi [~dajac]  Really bad, I am posting a new question due to the

  1   2   3   4   >