[jira] [Assigned] (KAFKA-16523) kafka-metadata-quorum add voter and remove voter changes

2024-06-06 Thread Deng Ziming (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16523?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Deng Ziming reassigned KAFKA-16523: --- Assignee: Deng Ziming > kafka-metadata-quorum add voter and remove voter changes >

[jira] [Created] (PARQUET-2477) Files opened by ParquetFileWriter’s appendFile method should to be closed correctly

2024-05-18 Thread Deng An (Jira)
Deng An created PARQUET-2477: Summary: Files opened by ParquetFileWriter’s appendFile method should to be closed correctly Key: PARQUET-2477 URL: https://issues.apache.org/jira/browse/PARQUET-2477

[jira] [Commented] (KAFKA-16211) Inconsistent config values in CreateTopicsResult and DescribeConfigsResult

2024-02-20 Thread Deng Ziming (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16211?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17819095#comment-17819095 ] Deng Ziming commented on KAFKA-16211: -   {code:java} // code placeholder @ExtendWith(value =

[jira] [Commented] (KAFKA-10140) Incremental config api excludes plugin config changes

2024-01-23 Thread Deng Ziming (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10140?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17810243#comment-17810243 ] Deng Ziming commented on KAFKA-10140: - This problem only affect append/subtract operations and will

[jira] [Created] (KAFKA-16181) Use incrementalAlterConfigs when updating broker configs by kafka-configs.sh

2024-01-21 Thread Deng Ziming (Jira)
Deng Ziming created KAFKA-16181: --- Summary: Use incrementalAlterConfigs when updating broker configs by kafka-configs.sh Key: KAFKA-16181 URL: https://issues.apache.org/jira/browse/KAFKA-16181 Project:

[jira] [Created] (KAFKA-16181) Use incrementalAlterConfigs when updating broker configs by kafka-configs.sh

2024-01-21 Thread Deng Ziming (Jira)
Deng Ziming created KAFKA-16181: --- Summary: Use incrementalAlterConfigs when updating broker configs by kafka-configs.sh Key: KAFKA-16181 URL: https://issues.apache.org/jira/browse/KAFKA-16181 Project:

[jira] [Resolved] (KAFKA-15619) Deleted topics will come back again

2023-12-25 Thread Deng Ziming (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15619?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Deng Ziming resolved KAFKA-15619. - Assignee: Deng Ziming Resolution: Invalid This has been fixed after setting

[jira] [Resolved] (KAFKA-15619) Deleted topics will come back again

2023-12-25 Thread Deng Ziming (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15619?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Deng Ziming resolved KAFKA-15619. - Assignee: Deng Ziming Resolution: Invalid This has been fixed after setting

[jira] [Updated] (SPARK-43258) Assign a name to the error class _LEGACY_ERROR_TEMP_202[3,4,5]

2023-11-10 Thread Deng Ziming (Jira)
[ https://issues.apache.org/jira/browse/SPARK-43258?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Deng Ziming updated SPARK-43258: Summary: Assign a name to the error class _LEGACY_ERROR_TEMP_202[3,4,5] (was: Assign a name to

[jira] [Resolved] (KAFKA-13005) Support JBOD in kraft mode

2023-10-31 Thread Deng Ziming (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13005?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Deng Ziming resolved KAFKA-13005. - Resolution: Duplicate > Support JBOD in kraft mode > -- > >

[jira] [Resolved] (KAFKA-13005) Support JBOD in kraft mode

2023-10-31 Thread Deng Ziming (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13005?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Deng Ziming resolved KAFKA-13005. - Resolution: Duplicate > Support JBOD in kraft mode > -- > >

[jira] [Updated] (FLINK-33406) Flink Job failed due to losing connection from ZK server

2023-10-31 Thread Deng Liwen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33406?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Deng Liwen updated FLINK-33406: --- Description: We are using Flink 1.14.3 and we faced an issue when losing connection from ZK

[jira] [Updated] (FLINK-33406) Flink Job failed due to losing connection from ZK server

2023-10-31 Thread Deng Liwen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33406?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Deng Liwen updated FLINK-33406: --- Description: We are using Flink 1.14.3 and we faced an issue when losing connection from ZK

[jira] [Created] (FLINK-33406) Flink Job failed due to losing connection from ZK server

2023-10-31 Thread Deng Liwen (Jira)
Deng Liwen created FLINK-33406: -- Summary: Flink Job failed due to losing connection from ZK server Key: FLINK-33406 URL: https://issues.apache.org/jira/browse/FLINK-33406 Project: Flink Issue

[jira] [Created] (FLINK-33406) Flink Job failed due to losing connection from ZK server

2023-10-31 Thread Deng Liwen (Jira)
Deng Liwen created FLINK-33406: -- Summary: Flink Job failed due to losing connection from ZK server Key: FLINK-33406 URL: https://issues.apache.org/jira/browse/FLINK-33406 Project: Flink Issue

[jira] [Created] (SPARK-45736) Use \s+ as separator when testing Kafka source or network source

2023-10-31 Thread Deng Ziming (Jira)
Deng Ziming created SPARK-45736: --- Summary: Use \s+ as separator when testing Kafka source or network source Key: SPARK-45736 URL: https://issues.apache.org/jira/browse/SPARK-45736 Project: Spark

[jira] [Updated] (SPARK-45710) Assign name to _LEGACY_ERROR_TEMP_21[59,60,61,62]

2023-10-27 Thread Deng Ziming (Jira)
[ https://issues.apache.org/jira/browse/SPARK-45710?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Deng Ziming updated SPARK-45710: Description: Choose a proper name for the error class

[jira] [Created] (SPARK-45710) Assign name to _LEGACY_ERROR_TEMP__LEGACY_ERROR_TEMP_21[59,60,61,62]

2023-10-27 Thread Deng Ziming (Jira)
Deng Ziming created SPARK-45710: --- Summary: Assign name to _LEGACY_ERROR_TEMP__LEGACY_ERROR_TEMP_21[59,60,61,62] Key: SPARK-45710 URL: https://issues.apache.org/jira/browse/SPARK-45710 Project: Spark

[jira] [Updated] (SPARK-45710) Assign name to _LEGACY_ERROR_TEMP_21[59,60,61,62]

2023-10-27 Thread Deng Ziming (Jira)
[ https://issues.apache.org/jira/browse/SPARK-45710?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Deng Ziming updated SPARK-45710: Summary: Assign name to _LEGACY_ERROR_TEMP_21[59,60,61,62] (was: Assign name to

[jira] [Resolved] (KAFKA-15390) FetchResponse.preferredReplica may contains fenced replica in KRaft mode

2023-10-26 Thread Deng Ziming (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15390?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Deng Ziming resolved KAFKA-15390. - Fix Version/s: 3.6.0 Resolution: Fixed > FetchResponse.preferredReplica may contains

[jira] [Resolved] (KAFKA-15390) FetchResponse.preferredReplica may contains fenced replica in KRaft mode

2023-10-26 Thread Deng Ziming (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15390?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Deng Ziming resolved KAFKA-15390. - Fix Version/s: 3.6.0 Resolution: Fixed > FetchResponse.preferredReplica may contains

[jira] [Created] (SPARK-45614) Assign name to _LEGACY_ERROR_TEMP_215[6,7,8]

2023-10-19 Thread Deng Ziming (Jira)
Deng Ziming created SPARK-45614: --- Summary: Assign name to _LEGACY_ERROR_TEMP_215[6,7,8] Key: SPARK-45614 URL: https://issues.apache.org/jira/browse/SPARK-45614 Project: Spark Issue Type:

[jira] [Updated] (SPARK-45569) Assign name to _LEGACY_ERROR_TEMP_2152

2023-10-19 Thread Deng Ziming (Jira)
[ https://issues.apache.org/jira/browse/SPARK-45569?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Deng Ziming updated SPARK-45569: Description: Choose a proper name for the error class *_LEGACY_ERROR_TEMP_2152* defined in

[jira] [Updated] (SPARK-45573) Assign name to _LEGACY_ERROR_TEMP_2153

2023-10-19 Thread Deng Ziming (Jira)
[ https://issues.apache.org/jira/browse/SPARK-45573?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Deng Ziming updated SPARK-45573: Description: Choose a proper name for the error class *_LEGACY_ERROR_TEMP_2153* defined in

[jira] [Created] (SPARK-45573) Assign name to _LEGACY_ERROR_TEMP_2153

2023-10-17 Thread Deng Ziming (Jira)
Deng Ziming created SPARK-45573: --- Summary: Assign name to _LEGACY_ERROR_TEMP_2153 Key: SPARK-45573 URL: https://issues.apache.org/jira/browse/SPARK-45573 Project: Spark Issue Type: Sub-task

[jira] [Created] (SPARK-45569) Assign name to _LEGACY_ERROR_TEMP_2152

2023-10-17 Thread Deng Ziming (Jira)
Deng Ziming created SPARK-45569: --- Summary: Assign name to _LEGACY_ERROR_TEMP_2152 Key: SPARK-45569 URL: https://issues.apache.org/jira/browse/SPARK-45569 Project: Spark Issue Type: Sub-task

[jira] [Commented] (KAFKA-15619) Deleted topics will come back again

2023-10-16 Thread Deng Ziming (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15619?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17776006#comment-17776006 ] Deng Ziming commented on KAFKA-15619: - Hello [~showuon] , As [~ijuma] mentioned,

[jira] [Updated] (KAFKA-15619) Deleted topics will come back again

2023-10-16 Thread Deng Ziming (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15619?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Deng Ziming updated KAFKA-15619: Description: Deleted topics will come back again in Apache Spark structured streaming stress

[jira] [Commented] (KAFKA-15619) Deleted topics will come back again

2023-10-16 Thread Deng Ziming (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15619?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17775988#comment-17775988 ] Deng Ziming commented on KAFKA-15619: - [~showuon] Yes, the stress test is using default config and

[jira] [Updated] (KAFKA-15619) Deleted topics will come back again

2023-10-16 Thread Deng Ziming (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15619?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Deng Ziming updated KAFKA-15619: Summary: Deleted topics will come back again (was: Kafka) > Deleted topics will come back again

[jira] [Created] (KAFKA-15619) Kafka

2023-10-16 Thread Deng Ziming (Jira)
Deng Ziming created KAFKA-15619: --- Summary: Kafka Key: KAFKA-15619 URL: https://issues.apache.org/jira/browse/KAFKA-15619 Project: Kafka Issue Type: Improvement Affects Versions: 3.5.1,

[jira] [Created] (KAFKA-15619) Kafka

2023-10-16 Thread Deng Ziming (Jira)
Deng Ziming created KAFKA-15619: --- Summary: Kafka Key: KAFKA-15619 URL: https://issues.apache.org/jira/browse/KAFKA-15619 Project: Kafka Issue Type: Improvement Affects Versions: 3.5.1,

[jira] [Created] (SPARK-45529) Fix flaky KafkaSourceStressSuite

2023-10-12 Thread Deng Ziming (Jira)
Deng Ziming created SPARK-45529: --- Summary: Fix flaky KafkaSourceStressSuite Key: SPARK-45529 URL: https://issues.apache.org/jira/browse/SPARK-45529 Project: Spark Issue Type: Improvement

[jira] [Commented] (SPARK-45502) Upgrade Kafka to 3.6.0

2023-10-11 Thread Deng Ziming (Jira)
[ https://issues.apache.org/jira/browse/SPARK-45502?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17773964#comment-17773964 ] Deng Ziming commented on SPARK-45502: - I'm trying this.  > Upgrade Kafka to 3.6.0 >

[jira] [Created] (KAFKA-15566) Klaky tests in FetchRequestTest.scala in KRaft mode

2023-10-09 Thread Deng Ziming (Jira)
Deng Ziming created KAFKA-15566: --- Summary: Klaky tests in FetchRequestTest.scala in KRaft mode Key: KAFKA-15566 URL: https://issues.apache.org/jira/browse/KAFKA-15566 Project: Kafka Issue

[jira] [Created] (KAFKA-15566) Klaky tests in FetchRequestTest.scala in KRaft mode

2023-10-09 Thread Deng Ziming (Jira)
Deng Ziming created KAFKA-15566: --- Summary: Klaky tests in FetchRequestTest.scala in KRaft mode Key: KAFKA-15566 URL: https://issues.apache.org/jira/browse/KAFKA-15566 Project: Kafka Issue

[jira] [Created] (SPARK-45236) ToPrettyString will treat java encoder or kryo encoder as BinaryType

2023-09-20 Thread Deng Ziming (Jira)
Deng Ziming created SPARK-45236: --- Summary: ToPrettyString will treat java encoder or kryo encoder as BinaryType Key: SPARK-45236 URL: https://issues.apache.org/jira/browse/SPARK-45236 Project: Spark

[jira] [Updated] (SPARK-45213) Assign name to _LEGACY_ERROR_TEMP_2151

2023-09-19 Thread Deng Ziming (Jira)
[ https://issues.apache.org/jira/browse/SPARK-45213?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Deng Ziming updated SPARK-45213: Description: in DatasetSuite test("CLASS_UNSUPPORTED_BY_MAP_OBJECTS when creating dataset") , we

[jira] [Updated] (SPARK-45213) Assign name to _LEGACY_ERROR_TEMP_2151

2023-09-19 Thread Deng Ziming (Jira)
[ https://issues.apache.org/jira/browse/SPARK-45213?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Deng Ziming updated SPARK-45213: Affects Version/s: 3.5.0 (was: 3.4.0) > Assign name to

[jira] [Updated] (SPARK-45213) Assign name to _LEGACY_ERROR_TEMP_2151

2023-09-19 Thread Deng Ziming (Jira)
[ https://issues.apache.org/jira/browse/SPARK-45213?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Deng Ziming updated SPARK-45213: Fix Version/s: (was: 3.4.0) > Assign name to _LEGACY_ERROR_TEMP_2151 >

[jira] [Created] (SPARK-45213) Assign name to _LEGACY_ERROR_TEMP_2151

2023-09-19 Thread Deng Ziming (Jira)
Deng Ziming created SPARK-45213: --- Summary: Assign name to _LEGACY_ERROR_TEMP_2151 Key: SPARK-45213 URL: https://issues.apache.org/jira/browse/SPARK-45213 Project: Spark Issue Type: Sub-task

[jira] [Commented] (KAFKA-15466) Add KIP-919 support for some admin APIs

2023-09-14 Thread Deng Ziming (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15466?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17765426#comment-17765426 ] Deng Ziming commented on KAFKA-15466: - We can split this to some separate tickets for easier code

[jira] [Resolved] (KAFKA-15315) Use getOrDefault rather than get

2023-09-11 Thread Deng Ziming (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15315?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Deng Ziming resolved KAFKA-15315. - Resolution: Fixed > Use getOrDefault rather than get > > >

[jira] [Resolved] (KAFKA-15315) Use getOrDefault rather than get

2023-09-11 Thread Deng Ziming (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15315?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Deng Ziming resolved KAFKA-15315. - Resolution: Fixed > Use getOrDefault rather than get > > >

[jira] [Reopened] (KAFKA-15140) Improve TopicCommandIntegrationTest to be less flaky

2023-09-10 Thread Deng Ziming (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15140?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Deng Ziming reopened KAFKA-15140: - This is still flaky, it seems the internal topic is also under min isr partitions.

[jira] [Reopened] (KAFKA-15140) Improve TopicCommandIntegrationTest to be less flaky

2023-09-10 Thread Deng Ziming (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15140?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Deng Ziming reopened KAFKA-15140: - This is still flaky, it seems the internal topic is also under min isr partitions.

[jira] [Resolved] (KAFKA-15286) Migrate ApiVersion related code to kraft

2023-09-10 Thread Deng Ziming (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15286?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Deng Ziming resolved KAFKA-15286. - Resolution: Fixed > Migrate ApiVersion related code to kraft >

[jira] [Resolved] (KAFKA-15286) Migrate ApiVersion related code to kraft

2023-09-10 Thread Deng Ziming (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15286?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Deng Ziming resolved KAFKA-15286. - Resolution: Fixed > Migrate ApiVersion related code to kraft >

[jira] [Commented] (SPARK-43252) Assign a name to the error class _LEGACY_ERROR_TEMP_2016

2023-09-06 Thread Deng Ziming (Jira)
[ https://issues.apache.org/jira/browse/SPARK-43252?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17762572#comment-17762572 ] Deng Ziming commented on SPARK-43252: - https://github.com/apache/spark/pull/42846 > Assign a name

[jira] [Commented] (SPARK-43251) Assign a name to the error class _LEGACY_ERROR_TEMP_2015

2023-09-06 Thread Deng Ziming (Jira)
[ https://issues.apache.org/jira/browse/SPARK-43251?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17762571#comment-17762571 ] Deng Ziming commented on SPARK-43251: - https://github.com/apache/spark/pull/42845 > Assign a name

[jira] [Created] (KAFKA-15390) FetchResponse.preferredReplica may contains fenced replica in KRaft mode

2023-08-21 Thread Deng Ziming (Jira)
Deng Ziming created KAFKA-15390: --- Summary: FetchResponse.preferredReplica may contains fenced replica in KRaft mode Key: KAFKA-15390 URL: https://issues.apache.org/jira/browse/KAFKA-15390 Project:

[jira] [Created] (KAFKA-15390) FetchResponse.preferredReplica may contains fenced replica in KRaft mode

2023-08-21 Thread Deng Ziming (Jira)
Deng Ziming created KAFKA-15390: --- Summary: FetchResponse.preferredReplica may contains fenced replica in KRaft mode Key: KAFKA-15390 URL: https://issues.apache.org/jira/browse/KAFKA-15390 Project:

[jira] [Commented] (KAFKA-15354) Partition leader is not evenly distributed in kraft mode

2023-08-20 Thread Deng Ziming (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15354?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17756637#comment-17756637 ] Deng Ziming commented on KAFKA-15354: - [~sagarrao] Yes, we are using a different way to assign

[jira] [Created] (KAFKA-15371) MetadataShell is stuck when bootstrapping

2023-08-16 Thread Deng Ziming (Jira)
Deng Ziming created KAFKA-15371: --- Summary: MetadataShell is stuck when bootstrapping Key: KAFKA-15371 URL: https://issues.apache.org/jira/browse/KAFKA-15371 Project: Kafka Issue Type: Bug

[jira] [Created] (KAFKA-15371) MetadataShell is stuck when bootstrapping

2023-08-16 Thread Deng Ziming (Jira)
Deng Ziming created KAFKA-15371: --- Summary: MetadataShell is stuck when bootstrapping Key: KAFKA-15371 URL: https://issues.apache.org/jira/browse/KAFKA-15371 Project: Kafka Issue Type: Bug

[jira] [Updated] (KAFKA-15354) Partition leader is not evenly distributed in kraft mode

2023-08-16 Thread Deng Ziming (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15354?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Deng Ziming updated KAFKA-15354: Issue Type: Bug (was: Improvement) > Partition leader is not evenly distributed in kraft mode >

[jira] [Created] (KAFKA-15354) Partition leader is not evenly distributed in kraft mode

2023-08-16 Thread Deng Ziming (Jira)
Deng Ziming created KAFKA-15354: --- Summary: Partition leader is not evenly distributed in kraft mode Key: KAFKA-15354 URL: https://issues.apache.org/jira/browse/KAFKA-15354 Project: Kafka Issue

[jira] [Created] (KAFKA-15354) Partition leader is not evenly distributed in kraft mode

2023-08-16 Thread Deng Ziming (Jira)
Deng Ziming created KAFKA-15354: --- Summary: Partition leader is not evenly distributed in kraft mode Key: KAFKA-15354 URL: https://issues.apache.org/jira/browse/KAFKA-15354 Project: Kafka Issue

[jira] [Resolved] (KAFKA-13836) Improve KRaft broker heartbeat logic

2023-08-14 Thread Deng Ziming (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13836?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Deng Ziming resolved KAFKA-13836. - Resolution: Won't Fix > Improve KRaft broker heartbeat logic >

[jira] [Resolved] (KAFKA-13836) Improve KRaft broker heartbeat logic

2023-08-14 Thread Deng Ziming (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13836?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Deng Ziming resolved KAFKA-13836. - Resolution: Won't Fix > Improve KRaft broker heartbeat logic >

[jira] [Resolved] (KAFKA-15289) Support KRaft mode in RequestQuotaTest

2023-08-14 Thread Deng Ziming (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15289?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Deng Ziming resolved KAFKA-15289. - Resolution: Fixed > Support KRaft mode in RequestQuotaTest >

[jira] [Resolved] (KAFKA-15289) Support KRaft mode in RequestQuotaTest

2023-08-14 Thread Deng Ziming (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15289?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Deng Ziming resolved KAFKA-15289. - Resolution: Fixed > Support KRaft mode in RequestQuotaTest >

[jira] [Created] (KAFKA-15340) Test request quota for kraft controller apis

2023-08-13 Thread Deng Ziming (Jira)
Deng Ziming created KAFKA-15340: --- Summary: Test request quota for kraft controller apis Key: KAFKA-15340 URL: https://issues.apache.org/jira/browse/KAFKA-15340 Project: Kafka Issue Type:

[jira] [Created] (KAFKA-15340) Test request quota for kraft controller apis

2023-08-13 Thread Deng Ziming (Jira)
Deng Ziming created KAFKA-15340: --- Summary: Test request quota for kraft controller apis Key: KAFKA-15340 URL: https://issues.apache.org/jira/browse/KAFKA-15340 Project: Kafka Issue Type:

[jira] [Assigned] (KAFKA-15334) DescribeQuorum should not be seen as cluster action

2023-08-13 Thread Deng Ziming (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15334?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Deng Ziming reassigned KAFKA-15334: --- Assignee: Sagar Rao > DescribeQuorum should not be seen as cluster action >

[jira] [Commented] (KAFKA-15334) DescribeQuorum should not be seen as cluster action

2023-08-13 Thread Deng Ziming (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15334?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17753876#comment-17753876 ] Deng Ziming commented on KAFKA-15334: - Thank you for your interestes [~sagarrao] , I assigned this

[jira] [Commented] (KAFKA-15334) DescribeQuorum should not be seen as cluster action

2023-08-11 Thread Deng Ziming (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15334?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17753070#comment-17753070 ] Deng Ziming commented on KAFKA-15334: - We are treating DescribeQuorum as cluster action, and not

[jira] [Created] (KAFKA-15334) DescribeQuorum should not be seen as cluster action

2023-08-11 Thread Deng Ziming (Jira)
Deng Ziming created KAFKA-15334: --- Summary: DescribeQuorum should not be seen as cluster action Key: KAFKA-15334 URL: https://issues.apache.org/jira/browse/KAFKA-15334 Project: Kafka Issue

[jira] [Created] (KAFKA-15334) DescribeQuorum should not be seen as cluster action

2023-08-11 Thread Deng Ziming (Jira)
Deng Ziming created KAFKA-15334: --- Summary: DescribeQuorum should not be seen as cluster action Key: KAFKA-15334 URL: https://issues.apache.org/jira/browse/KAFKA-15334 Project: Kafka Issue

[jira] [Updated] (KAFKA-15289) Support KRaft mode in RequestQuotaTest

2023-08-10 Thread Deng Ziming (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15289?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Deng Ziming updated KAFKA-15289: Description: we are calling `zkBrokerApis` in , we should ensure kraft broker apis are also

[jira] [Updated] (KAFKA-15289) Support KRaft mode in RequestQuotaTest

2023-08-10 Thread Deng Ziming (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15289?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Deng Ziming updated KAFKA-15289: Description: we are calling `zkBrokerApis` in RequestQuotaTest, we should ensure kraft broker

[jira] [Updated] (KAFKA-15289) Support KRaft mode in RequestQuotaTest

2023-08-10 Thread Deng Ziming (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15289?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Deng Ziming updated KAFKA-15289: Summary: Support KRaft mode in RequestQuotaTest (was: Use zkBrokerApis.clientApis instead of

[jira] [Resolved] (KAFKA-15287) Change NodeApiVersions.create() to contains both apis of zk and kraft broker

2023-08-10 Thread Deng Ziming (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15287?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Deng Ziming resolved KAFKA-15287. - Resolution: Fixed > Change NodeApiVersions.create() to contains both apis of zk and kraft

[jira] [Resolved] (KAFKA-15287) Change NodeApiVersions.create() to contains both apis of zk and kraft broker

2023-08-10 Thread Deng Ziming (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15287?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Deng Ziming resolved KAFKA-15287. - Resolution: Fixed > Change NodeApiVersions.create() to contains both apis of zk and kraft

[jira] [Resolved] (KAFKA-15288) Change BrokerApiVersionsCommandTest to support kraft mode

2023-08-10 Thread Deng Ziming (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15288?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Deng Ziming resolved KAFKA-15288. - Resolution: Fixed > Change BrokerApiVersionsCommandTest to support kraft mode >

[jira] [Resolved] (KAFKA-15288) Change BrokerApiVersionsCommandTest to support kraft mode

2023-08-10 Thread Deng Ziming (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15288?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Deng Ziming resolved KAFKA-15288. - Resolution: Fixed > Change BrokerApiVersionsCommandTest to support kraft mode >

[jira] [Created] (SPARK-44673) Raise a ArrowIOError with empty messages

2023-08-04 Thread Deng An (Jira)
Deng An created SPARK-44673: --- Summary: Raise a ArrowIOError with empty messages Key: SPARK-44673 URL: https://issues.apache.org/jira/browse/SPARK-44673 Project: Spark Issue Type: Bug

[jira] [Updated] (KAFKA-15288) Change BrokerApiVersionsCommandTest to support kraft mode

2023-08-01 Thread Deng Ziming (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15288?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Deng Ziming updated KAFKA-15288: Description: Currently we only test zk mode for  (was: Currently ) > Change

[jira] [Updated] (KAFKA-15288) Change BrokerApiVersionsCommandTest to support kraft mode

2023-08-01 Thread Deng Ziming (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15288?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Deng Ziming updated KAFKA-15288: Description: Currently we only test zk mode for BrokerApiVersionsCommand (was: Currently we only

[jira] [Created] (KAFKA-15289) Use zkBrokerApis.clientApis instead of ApiKeys.zkBrokerApis in most cases

2023-08-01 Thread Deng Ziming (Jira)
Deng Ziming created KAFKA-15289: --- Summary: Use zkBrokerApis.clientApis instead of ApiKeys.zkBrokerApis in most cases Key: KAFKA-15289 URL: https://issues.apache.org/jira/browse/KAFKA-15289 Project:

[jira] [Created] (KAFKA-15289) Use zkBrokerApis.clientApis instead of ApiKeys.zkBrokerApis in most cases

2023-08-01 Thread Deng Ziming (Jira)
Deng Ziming created KAFKA-15289: --- Summary: Use zkBrokerApis.clientApis instead of ApiKeys.zkBrokerApis in most cases Key: KAFKA-15289 URL: https://issues.apache.org/jira/browse/KAFKA-15289 Project:

[jira] [Created] (KAFKA-15288) Change BrokerApiVersionsCommandTest to support kraft mode

2023-08-01 Thread Deng Ziming (Jira)
Deng Ziming created KAFKA-15288: --- Summary: Change BrokerApiVersionsCommandTest to support kraft mode Key: KAFKA-15288 URL: https://issues.apache.org/jira/browse/KAFKA-15288 Project: Kafka

[jira] [Created] (KAFKA-15288) Change BrokerApiVersionsCommandTest to support kraft mode

2023-08-01 Thread Deng Ziming (Jira)
Deng Ziming created KAFKA-15288: --- Summary: Change BrokerApiVersionsCommandTest to support kraft mode Key: KAFKA-15288 URL: https://issues.apache.org/jira/browse/KAFKA-15288 Project: Kafka

[jira] [Created] (KAFKA-15287) Change NodeApiVersions.create() to contains both apis of zk and kraft broker

2023-08-01 Thread Deng Ziming (Jira)
Deng Ziming created KAFKA-15287: --- Summary: Change NodeApiVersions.create() to contains both apis of zk and kraft broker Key: KAFKA-15287 URL: https://issues.apache.org/jira/browse/KAFKA-15287 Project:

[jira] [Created] (KAFKA-15287) Change NodeApiVersions.create() to contains both apis of zk and kraft broker

2023-08-01 Thread Deng Ziming (Jira)
Deng Ziming created KAFKA-15287: --- Summary: Change NodeApiVersions.create() to contains both apis of zk and kraft broker Key: KAFKA-15287 URL: https://issues.apache.org/jira/browse/KAFKA-15287 Project:

[jira] [Created] (KAFKA-15286) Migrate ApiVersion related code to kraft

2023-08-01 Thread Deng Ziming (Jira)
Deng Ziming created KAFKA-15286: --- Summary: Migrate ApiVersion related code to kraft Key: KAFKA-15286 URL: https://issues.apache.org/jira/browse/KAFKA-15286 Project: Kafka Issue Type: Task

[jira] [Created] (KAFKA-15286) Migrate ApiVersion related code to kraft

2023-08-01 Thread Deng Ziming (Jira)
Deng Ziming created KAFKA-15286: --- Summary: Migrate ApiVersion related code to kraft Key: KAFKA-15286 URL: https://issues.apache.org/jira/browse/KAFKA-15286 Project: Kafka Issue Type: Task

[jira] [Resolved] (KAFKA-15036) Kraft leader change fails when invoking getFinalizedFeatures

2023-06-11 Thread Deng Ziming (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15036?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Deng Ziming resolved KAFKA-15036. - Resolution: Fixed > Kraft leader change fails when invoking getFinalizedFeatures >

[jira] [Resolved] (KAFKA-15036) Kraft leader change fails when invoking getFinalizedFeatures

2023-06-11 Thread Deng Ziming (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15036?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Deng Ziming resolved KAFKA-15036. - Resolution: Fixed > Kraft leader change fails when invoking getFinalizedFeatures >

[jira] [Updated] (KAFKA-15065) ApiVersionRequest is not properly handled in Sasl ControllerServer

2023-06-07 Thread Deng Ziming (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15065?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Deng Ziming updated KAFKA-15065: Issue Type: Bug (was: Improvement) > ApiVersionRequest is not properly handled in Sasl

[jira] [Created] (KAFKA-15065) ApiVersionRequest is not properly handled in Sasl ControllerServer

2023-06-07 Thread Deng Ziming (Jira)
Deng Ziming created KAFKA-15065: --- Summary: ApiVersionRequest is not properly handled in Sasl ControllerServer Key: KAFKA-15065 URL: https://issues.apache.org/jira/browse/KAFKA-15065 Project: Kafka

[jira] [Created] (KAFKA-15065) ApiVersionRequest is not properly handled in Sasl ControllerServer

2023-06-07 Thread Deng Ziming (Jira)
Deng Ziming created KAFKA-15065: --- Summary: ApiVersionRequest is not properly handled in Sasl ControllerServer Key: KAFKA-15065 URL: https://issues.apache.org/jira/browse/KAFKA-15065 Project: Kafka

[jira] [Assigned] (KAFKA-15036) Kraft leader change fails when invoking getFinalizedFeatures

2023-05-29 Thread Deng Ziming (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15036?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Deng Ziming reassigned KAFKA-15036: --- Assignee: Deng Ziming > Kraft leader change fails when invoking getFinalizedFeatures >

[jira] [Created] (KAFKA-15036) Kraft leader change fails when invoking getFinalizedFeatures

2023-05-29 Thread Deng Ziming (Jira)
Deng Ziming created KAFKA-15036: --- Summary: Kraft leader change fails when invoking getFinalizedFeatures Key: KAFKA-15036 URL: https://issues.apache.org/jira/browse/KAFKA-15036 Project: Kafka

[jira] [Created] (KAFKA-15036) Kraft leader change fails when invoking getFinalizedFeatures

2023-05-29 Thread Deng Ziming (Jira)
Deng Ziming created KAFKA-15036: --- Summary: Kraft leader change fails when invoking getFinalizedFeatures Key: KAFKA-15036 URL: https://issues.apache.org/jira/browse/KAFKA-15036 Project: Kafka

[jira] [Commented] (KAFKA-14989) Flaky test TransactionsTest.testFailureToFenceEpoch

2023-05-11 Thread Deng Ziming (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14989?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17721762#comment-17721762 ] Deng Ziming commented on KAFKA-14989: -

[jira] [Created] (KAFKA-14989) Flaky test TransactionsTest.testFailureToFenceEpoch

2023-05-11 Thread Deng Ziming (Jira)
Deng Ziming created KAFKA-14989: --- Summary: Flaky test TransactionsTest.testFailureToFenceEpoch Key: KAFKA-14989 URL: https://issues.apache.org/jira/browse/KAFKA-14989 Project: Kafka Issue

[jira] [Created] (KAFKA-14989) Flaky test TransactionsTest.testFailureToFenceEpoch

2023-05-11 Thread Deng Ziming (Jira)
Deng Ziming created KAFKA-14989: --- Summary: Flaky test TransactionsTest.testFailureToFenceEpoch Key: KAFKA-14989 URL: https://issues.apache.org/jira/browse/KAFKA-14989 Project: Kafka Issue

[jira] [Reopened] (KAFKA-14291) KRaft: ApiVersionsResponse doesn't have finalizedFeatures and finalizedFeatureEpoch in KRaft mode

2023-05-06 Thread Deng Ziming (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14291?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Deng Ziming reopened KAFKA-14291: - Assignee: Deng Ziming > KRaft: ApiVersionsResponse doesn't have finalizedFeatures and >

[jira] [Reopened] (KAFKA-14291) KRaft: ApiVersionsResponse doesn't have finalizedFeatures and finalizedFeatureEpoch in KRaft mode

2023-05-06 Thread Deng Ziming (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14291?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Deng Ziming reopened KAFKA-14291: - Assignee: Deng Ziming > KRaft: ApiVersionsResponse doesn't have finalizedFeatures and >

  1   2   3   >