[jira] [Resolved] (KAFKA-18441) Fix flaky KafkaAdminClientTest#testAdminClientApisAuthenticationFailure

[ https://issues.apache.org/jira/browse/KAFKA-18441?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] PoAn Yang resolved KAFKA-18441. --- Resolution: Fixed > Fix flaky KafkaAdminClientTest#testAdminClientApisAuthenticationFailure > --

request to create an Kafka account

*Dear Kafka Dev Team,* I hope this email finds you well. I am writing to formally request the creation of an Apache account in order to submit and contribute to Kafka Improvement Proposals (KIP). Best regards, Xuan-Zhang Gong

[jira] [Resolved] (KAFKA-18770) Fix flaky initializationError in ReplicationQuotasTest/RequestQuotaTest (thread leak)

[ https://issues.apache.org/jira/browse/KAFKA-18770?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai resolved KAFKA-18770. Resolution: Fixed > Fix flaky initializationError in ReplicationQuotasTest/RequestQuotaTes

[jira] [Resolved] (KAFKA-18366) Remove KafkaConfig.interBrokerProtocolVersion

[ https://issues.apache.org/jira/browse/KAFKA-18366?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai resolved KAFKA-18366. Resolution: Fixed trunk: [https://github.com/apache/kafka/commit/581e94840fd0503d46c36eb8

Jenkins build is still unstable: Kafka » Kafka Branch Builder » 3.8 #146

See

Jenkins build is still unstable: Kafka » Kafka Branch Builder » 3.9 #161

See

[jira] [Resolved] (KAFKA-18658) add import control for examples module

[ https://issues.apache.org/jira/browse/KAFKA-18658?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai resolved KAFKA-18658. Resolution: Fixed > add import control for examples module > -

Re: Clarifying Kafka Raft - Reg

Hi Rameshkanna N, My reading based on the KIP-631 is the quorum-based Kafka controller stores metadata. The leader of this controller quorum writes to the metadata topic partition, and the followers replicate it. From the perspective of administrative task, this description is enough. KIP-63

[jira] [Resolved] (KAFKA-18743) leader.imbalance.per.broker.percentage is not supported by Kraft

[ https://issues.apache.org/jira/browse/KAFKA-18743?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai resolved KAFKA-18743. Resolution: Fixed trunk: [https://github.com/apache/kafka/commit/4e36368d08e107d83431dbda

[jira] [Created] (KAFKA-18771) Flaky test KRaftClusterTest .testDescribeQuorumRequestToControllers

Matthias J. Sax created KAFKA-18771: --- Summary: Flaky test KRaftClusterTest .testDescribeQuorumRequestToControllers Key: KAFKA-18771 URL: https://issues.apache.org/jira/browse/KAFKA-18771 Project: Ka

Clarifying Kafka Raft - Reg

Hi team, In Zookeeper based Kafka mode, one of the Kafka brokers can act as a controller for performing administrative tasks. In new launch of Kafka, KRaft mode introduced. In KRaft eliminates the Zookeeper dependency and uses Raft algorithm for managing meta data. Now my query is in KRaft mode, i

Re: [DISCUSS] KIP-971 Expose replication-offset-lag MirrorMaker2 metric

Hi, I realized I did not include the MBeans attribute in my previous email. I meant the records-lag attribute from kafka.consumer:type=consumer-fetch-manager-metrics,partition="{partition}",topic="{topic}",client-id="{client-id}". Quickly looking at the code, that metric seems to come from the sam

Re: [DISCUSS] KIP-971 Expose replication-offset-lag MirrorMaker2 metric

Hi, I'm very late to this discussion, but I saw the part about the performance impact of fetching the LEOs - I was curious how that was exactly experienced? Was it using consumer.endOffsets()? There is also a consumer.currentLag() method, which uses locally-cached LEO info. It might not be as preci

[jira] [Resolved] (KAFKA-806) Index may not always observe log.index.interval.bytes

[ https://issues.apache.org/jira/browse/KAFKA-806?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai resolved KAFKA-806. -- Fix Version/s: 3.9.1 3.8.2 Resolution: Fixed trunk: https://github.co

[jira] [Reopened] (KAFKA-806) Index may not always observe log.index.interval.bytes

[ https://issues.apache.org/jira/browse/KAFKA-806?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai reopened KAFKA-806: -- > Index may not always observe log.index.interval.bytes > --

[jira] [Created] (KAFKA-18770) Fix flaky initializationError in ReplicationQuotasTest/RequestQuotaTest (thread leak)

Yu-Lin Chen created KAFKA-18770: --- Summary: Fix flaky initializationError in ReplicationQuotasTest/RequestQuotaTest (thread leak) Key: KAFKA-18770 URL: https://issues.apache.org/jira/browse/KAFKA-18770 P

[jira] [Created] (KAFKA-18769) Handle leader changes in client to ensure we do not send requests to the previous leader

Shivsundar R created KAFKA-18769: Summary: Handle leader changes in client to ensure we do not send requests to the previous leader Key: KAFKA-18769 URL: https://issues.apache.org/jira/browse/KAFKA-18769

[jira] [Created] (KAFKA-18768) Backport KAFKA-806 to 4.0

Chia-Ping Tsai created KAFKA-18768: -- Summary: Backport KAFKA-806 to 4.0 Key: KAFKA-18768 URL: https://issues.apache.org/jira/browse/KAFKA-18768 Project: Kafka Issue Type: Sub-task

[jira] [Resolved] (KAFKA-18759) The replicas followers may create mismatches indexes

[ https://issues.apache.org/jira/browse/KAFKA-18759?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai resolved KAFKA-18759. Fix Version/s: (was: 3.9.1) (was: 3.8.2) Resolution: Dupl

[jira] [Resolved] (KAFKA-18225) ClientQuotaCallback#updateClusterMetadata is unsupported by kraft

[ https://issues.apache.org/jira/browse/KAFKA-18225?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai resolved KAFKA-18225. Resolution: Fixed trunk: https://github.com/apache/kafka/commit/70adf746c472f9136a6e7b7bc

[jira] [Created] (KAFKA-18767) Add client side config check

TaiJuWu created KAFKA-18767: --- Summary: Add client side config check Key: KAFKA-18767 URL: https://issues.apache.org/jira/browse/KAFKA-18767 Project: Kafka Issue Type: Sub-task Reporter:

[jira] [Created] (KAFKA-18766) Docs: Make usage of allow.everyone.if.no.acl.found config clearer

Divij Vaidya created KAFKA-18766: Summary: Docs: Make usage of allow.everyone.if.no.acl.found config clearer Key: KAFKA-18766 URL: https://issues.apache.org/jira/browse/KAFKA-18766 Project: Kafka

Re: [DISCUSS] KIP-971 Expose replication-offset-lag MirrorMaker2 metric

Hi, I looked at this again today and I was wondering how if would compare against the lag reported by consumers. Could we use the kafka.consumer:type=consumer-fetch-manager-metrics,partition="{partition}",topic="{topic}",client-id="{client-id}" metric that already exists? If not, let's add this to

[jira] [Created] (KAFKA-18765) Custom StreamsPartitioner for auto-repartitioning

Nicholas Telford created KAFKA-18765: Summary: Custom StreamsPartitioner for auto-repartitioning Key: KAFKA-18765 URL: https://issues.apache.org/jira/browse/KAFKA-18765 Project: Kafka Iss

[jira] [Created] (KAFKA-18764) Cluster-authorized share-state RPCs should throttle when not authorized

Andrew Schofield created KAFKA-18764: Summary: Cluster-authorized share-state RPCs should throttle when not authorized Key: KAFKA-18764 URL: https://issues.apache.org/jira/browse/KAFKA-18764 Proje

[jira] [Created] (KAFKA-18763) Resolve the flakiness in test_share_single_topic_partition system test

Chirag Wadhwa created KAFKA-18763: - Summary: Resolve the flakiness in test_share_single_topic_partition system test Key: KAFKA-18763 URL: https://issues.apache.org/jira/browse/KAFKA-18763 Project: Kaf

Re: Manage dynamic members through java admin client

Hi Tsai, Thanks for your quick response and sorry for the late reply, i'm involved in some other investigations that are consuming my time, but i'm going to move forward on this one from now on. Your questions are really pointing the spot though, and guess i kinda anticipated them in the last pie

[jira] [Created] (KAFKA-18762) 'Acks=all' not working correctly in Kafka Kraft mode.

Shubham Raj created KAFKA-18762: --- Summary: 'Acks=all' not working correctly in Kafka Kraft mode. Key: KAFKA-18762 URL: https://issues.apache.org/jira/browse/KAFKA-18762 Project: Kafka Issue Typ