[jira] [Created] (KAFKA-19298) Move RuntimeLoggerManager to server module

Chia-Ping Tsai created KAFKA-19298: -- Summary: Move RuntimeLoggerManager to server module Key: KAFKA-19298 URL: https://issues.apache.org/jira/browse/KAFKA-19298 Project: Kafka Issue Type: Su

Jenkins build is still unstable: Kafka » Kafka PowerPC Daily » test-powerpc #300

See

[jira] [Created] (KAFKA-19297) Refactor AsyncKafkaConsumer's use of Java Streams APIs in critical sections

Kirk True created KAFKA-19297: - Summary: Refactor AsyncKafkaConsumer's use of Java Streams APIs in critical sections Key: KAFKA-19297 URL: https://issues.apache.org/jira/browse/KAFKA-19297 Project: Kafka

[jira] [Created] (KAFKA-19296) Revise AsyncKafkaConsumer event wakeup approach

Kirk True created KAFKA-19296: - Summary: Revise AsyncKafkaConsumer event wakeup approach Key: KAFKA-19296 URL: https://issues.apache.org/jira/browse/KAFKA-19296 Project: Kafka Issue Type: Improve

[jira] [Created] (KAFKA-19295) Remove AsyncKafkaConsumer event ID generation

Kirk True created KAFKA-19295: - Summary: Remove AsyncKafkaConsumer event ID generation Key: KAFKA-19295 URL: https://issues.apache.org/jira/browse/KAFKA-19295 Project: Kafka Issue Type: Improveme

[jira] [Created] (KAFKA-19294) Fix BrokerLifecycleManager RPC timeouts

Colin McCabe created KAFKA-19294: Summary: Fix BrokerLifecycleManager RPC timeouts Key: KAFKA-19294 URL: https://issues.apache.org/jira/browse/KAFKA-19294 Project: Kafka Issue Type: Bug

[jira] [Created] (KAFKA-19293) Consolidate writes within GroupCoordinatorService#onPartitionsDeleted

David Jacot created KAFKA-19293: --- Summary: Consolidate writes within GroupCoordinatorService#onPartitionsDeleted Key: KAFKA-19293 URL: https://issues.apache.org/jira/browse/KAFKA-19293 Project: Kafka

Re: [DISCUSS] KIP-1150 Diskless Topics

Hi, Giuseppe, Ivan, Thanks for the reply. JR1. Sounds good. It would be useful to document the benefit from each major Cloud in the KIP. JR2. "The same tiered storage doesn’t support compacted topics and the community seems fine with this, because compacted topics are not often that big to benef

[jira] [Created] (KAFKA-19292) Introduce soft state for StreamsGroup

Bill Bejeck created KAFKA-19292: --- Summary: Introduce soft state for StreamsGroup Key: KAFKA-19292 URL: https://issues.apache.org/jira/browse/KAFKA-19292 Project: Kafka Issue Type: Sub-task

[jira] [Resolved] (KAFKA-19141) Persist topic id in OffsetCommit record

[ https://issues.apache.org/jira/browse/KAFKA-19141?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Jacot resolved KAFKA-19141. - Fix Version/s: 4.1.0 Resolution: Fixed > Persist topic id in OffsetCommit record > --

Re: [DISCUSS] KIP-1150 Diskless Topics

On Tue, May 13, 2025, at 19:34, Jun Rao wrote: > > JR4. "Balance traffic among brokers and eliminate broker hotspots with > per-client granularity". Does that mean all traffic from a client is served > from a single broker? This seems to reduce the scalability from the client > perspective. We p

Re: [DISCUSS] KIP-1150 Diskless Topics

On Tue, May 13, 2025, at 19:34, Jun Rao wrote: > JR3. "Permit multi-region active-active topics with automatic failover". > Could you elaborate on the benefit of this? Cloud providers still charge > cross region data transfer in object stores, right? First, we should have emphasized in the KIP th

Re: [DISCUSS] KIP-1150 Diskless Topics

Hi Jun, Thank you for your questions! On Tue, May 13, 2025, at 19:34, Jun Rao wrote: > Hi, Josep, > > Thanks for the KIP. At the highlevel, the KIP is well thought through and > provides multiple benefits for Kafka in the Cloud. A few comments below. > > JR1. One of the key motivations is to el

Re: [VOTE] 3.9.1 RC2

Hello, I've completed the following tests on my local machine: - Built from source using JDK 21 & JDK 17 - Executed all unit and integration tests - Ran the KRaft quickstart successfully - test console producer and consumer Best Regards Jiunn-Yang > Mickael Maison 於 2025年5月16日 下午5:28 寫道： >

Kafka setup with OAuth2 for client-broker and PLAINTEXT for inter-broker

Hi All, I am trying to have a kafka configuration where we use *OAuth2 for client broker communication and PLAINTEXT for inter broker communication. Kafa broker should not need to talk to the OAuth server. * THis is what the configuration looks like: advertised.listeners is set to SASL_PLAINTEXT

Re: [DISCUSS] KIP-1150 Diskless Topics

Hello Jun, Thank you for your interest in the KIP. Regarding your question about transactions: > JR2. Transactions on Diskless Topics is listed in the future work. > Currently, we try to support all existing client APIs for every new > feature. For example, remote storage (KIP-405) supports tran

[jira] [Created] (KAFKA-19291) Increase the timeout of remote storage share fetch requests in purgatory

Abhinav Dixit created KAFKA-19291: - Summary: Increase the timeout of remote storage share fetch requests in purgatory Key: KAFKA-19291 URL: https://issues.apache.org/jira/browse/KAFKA-19291 Project: K

Re: [VOTE] 3.9.1 RC2

Hi, I checked the following: - validated checksums/signatures - ran quickstart with both KRaft and ZK with 2.13 binaries, apache/kafka:3.9.1-rc2 and apache/kafka-native:3.9.1-rc2 - ran unit/integration tests from source artifact +1 (binding) Thanks for running the release! Mickael On Thu, May

[jira] [Created] (KAFKA-19290) Exploit mapKey optimisation in protocol requests and responses

Andrew Schofield created KAFKA-19290: Summary: Exploit mapKey optimisation in protocol requests and responses Key: KAFKA-19290 URL: https://issues.apache.org/jira/browse/KAFKA-19290 Project: Kafka