[jira] [Created] (KAFKA-19079) KIP-890 Cleanups

Justine Olshan created KAFKA-19079: -- Summary: KIP-890 Cleanups Key: KAFKA-19079 URL: https://issues.apache.org/jira/browse/KAFKA-19079 Project: Kafka Issue Type: Improvement Repo

[jira] [Resolved] (KAFKA-18949) fix testDeleteRecordsAfterCorruptRecords for consumer protocol

[ https://issues.apache.org/jira/browse/KAFKA-18949?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai resolved KAFKA-18949. Fix Version/s: 4.1.0 Resolution: Fixed > fix testDeleteRecordsAfterCorruptRecords f

[jira] [Resolved] (KAFKA-18781) Extend RefreshRetriableException related exceptions

[ https://issues.apache.org/jira/browse/KAFKA-18781?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kaushik Raina resolved KAFKA-18781. --- Resolution: Fixed > Extend RefreshRetriableException related exceptions > --

[jira] [Created] (KAFKA-19076) UnifiedLog#maybeHandleIOException should replace `String` by `Supplier`

Chia-Ping Tsai created KAFKA-19076: -- Summary: UnifiedLog#maybeHandleIOException should replace `String` by `Supplier` Key: KAFKA-19076 URL: https://issues.apache.org/jira/browse/KAFKA-19076 Project:

Re: 回复： [DISCUSS] KIP-1134: Virtual Clusters in Kafka

Hi Greg, 1. Sorry, I don't exactly understand your question, mainly the cattle/pet reference :). I think naming may not need to be connected to access. I'd rather use ACLs to limit access of non-VC users to VC-linked topics. 2. Yes, with UUID-first generation prefix ACLs are unusable and I think

Re: [DISCUSS] Apache Kafka 4.1.0 release

Hi, You can find the release plan in the wiki: https://cwiki.apache.org/confluence/display/KAFKA/Release+Plan+4.1.0 Thanks, Mickael On Fri, Mar 21, 2025 at 8:15 PM José Armando García Sancio wrote: > > Thanks Mickael. > > On Wed, Mar 19, 2025 at 9:20 AM Ismael Juma wrote: > > > > Thanks Micka

[jira] [Resolved] (KAFKA-19058) Running the streams/streams-scala module tests produces a streams-scala.log

[ https://issues.apache.org/jira/browse/KAFKA-19058?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-19058. - Fix Version/s: 4.1.0 Resolution: Fixed > Running the streams/streams-scala module

Re: [DISCUSS] Git commits and metadata

I see two problems that this solves. 1) Gets the history of approver out of GitHub and into our log (no need to look back at the PR) 2) Gives proper attribution for the single person responsible for committing/approving the code (untangle all the "Reviewers:") And yea, I think it can be totally a

Re: Kafka support for Java 24+

Hi Luke, I took a look at getting 3.9 to run Java 23 on CI in this PR https://github.com/apache/kafka/pull/19311 which is just 3.9 plus all the other backport PRs, plus a few extra backports and changes to get Java 23 to build locally. I was planning to raise PRs for these bits individually once I

[jira] [Created] (KAFKA-19080) The constraint on segment.ms is not enforced at topic level

Jun Rao created KAFKA-19080: --- Summary: The constraint on segment.ms is not enforced at topic level Key: KAFKA-19080 URL: https://issues.apache.org/jira/browse/KAFKA-19080 Project: Kafka Issue Type

Re: [DISCUSS] KIP-1146: Anchored wall-clock punctuation

Thanks for the KIP! I pretty much echo what Matthias has said so far regarding the API. Regarding #4-5, assuming we would just be leaving out stream-time in the initial implementation for time/scope reasons and might want to add this in the future, I think it's best to just throw an exception if

Re: [DISCUSS] KIP-1138: Clean up TopologyConfig and API for supplying configs needed by the topology

Sounds like we are in agreement and can move forward with this KIP. To sum, instead of having the new StreamsBuilder and Topology constructors take a StreamsConfig parameter, they should take a Map or Properties instead. Between the two of those I don't personally have much of a preference, and s

Re: kafka 4.0.0 running on java 11

hi Max > Will there be a backdated version? If we are unable to upgrade to java 17? 3.x still support ava 8, and we will maintain 3.9 for a while. However, not all features will be backport to 3.9, so it would be good to consider using java 17 in order to upgrade to 4.x for server side. Best, Ch

Re: [DISCUSS] Proposal: Kafka Streams PHP Extension - KStreamsJS-PHP

hi Elvis Thanks for this proposal. It is great and I totally agree we should embrace the PHP to make Kafka great again. BTW, is PHP popular in your planet? I assume PHP is popular in the earth only. It would be great to ensure Kafka is compatible with all planets in this universe. Best, ch

Re: Kafka support for Java 24+

Hi Stig and all, For backporting the change to 3.9, if there's no objections, I think we can start to merge them tomorrow. For the Java 24 testing, it's fine we ship 3.9 without Java 24 test if gradle release is delayed since this is also the state of what Kafka v4.0 is. So we should firstly test

[jira] [Created] (KAFKA-19078) Implement automatic controller addition to cluster metadata partition

José Armando García Sancio created KAFKA-19078: -- Summary: Implement automatic controller addition to cluster metadata partition Key: KAFKA-19078 URL: https://issues.apache.org/jira/browse/KAFKA-19078

RE: Re: Kafka support for Java 24+

Hi, Keeping our fingers crossed for this backport to make it into 3.9. We are using Kafka client as a 3rd, and 4th party dependency (through Confluent Parallel Consumer - @astubbs), in a collection of Helidon MP 4.1.6 microservices. When do you estimate would we know for sure whether it will be

[jira] [Resolved] (KAFKA-19004) Move DelayedDeleteRecords to server-common module

[ https://issues.apache.org/jira/browse/KAFKA-19004?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai resolved KAFKA-19004. Fix Version/s: 4.1.0 Resolution: Fixed > Move DelayedDeleteRecords to server-common

Re: Kafka support for Java 24+

Hi all, Just keep in mind that *Gradle version 8.14 *(currently under development) will support *Java 24*: - https://docs.gradle.org/8.13/userguide/compatibility.html - https://github.com/gradle/gradle/issues/32290#issuecomment-2741096604 - https://github.com/gradle/gradle/issues/32289#i

Re: [DISCUSS] KIP-1136: Make ConsumerGroupMetadata an interface

I double checked everything and unfortunately even when I created internal and external representation of ConsumerGroupMetadata, this did not help. The reasons why are as follows: 1. ConsumerCoordinator is evaluating the onAssignment method from ConsumerPartitionAssignor which is a public in

Re: KIP-1141: Simplifying MetadataQuorumCommand by Leveraging Admin API for Controller Management

Hi Kuan, I took a look at your KIP and thought about the problem and possible solutions. For the add-controller command, the active controller needs to know the new controller's id, directory id and endpoints for the default listener. As you mentioned in your KIP the user can provide the id using

[jira] [Resolved] (KAFKA-19067) AsyncKafkaConsumer may return stale fetch result after seek operation

[ https://issues.apache.org/jira/browse/KAFKA-19067?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] PoAn Yang resolved KAFKA-19067. --- Resolution: Won't Fix > AsyncKafkaConsumer may return stale fetch result after seek operation >

Re: [DISCUSS] Proposal: Kafka Streams PHP Extension - KStreamsJS-PHP

This is indeed a game-changing feature. +1 (April) Best, Penguin Bruno Cadonna 於 2025年4月2日 週三 下午3:43寫道： > Great idea! > PHP is the way to go! > > +1 (April) > > Best, > Bruno > > On 02.04.25 02:18, Matthias J. Sax wrote: > > Sounds like a great idea, Bill! We all know that Java is dead, but th

Re: [DISCUSS] KIP-1142: Allow to list non-existent group which has dynamic config

Hi PoAn, I’ve re-read the KIP and have another question. AS5: I wonder whether it is possible using kafka-configs.sh to list out the configs for all group entities. I see that the example for "--describe --entity-type groups” actually includes a specific named entity. Does this KIP change the outp

Re: [VOTE] KIP-1133: AK Documentation and Website in Markdown

Thanks a lot for the KIP! +1 (binding) Best, Bruno On 02.04.25 02:57, Matthias J. Sax wrote: +1 (binding) On 3/27/25 2:39 AM, TengYao Chi wrote: Hi Harish, Thanks for this EPIC KIP. +1 (non-binding) Sincerely, TengYao Andrew Schofield 於 2025年3月27日 週四 下午5:32寫道： Hi Harish, Thanks for t

Re: [VOTE] KIP-1133: AK Documentation and Website in Markdown

Thanks for the KIP. Look forward to using Hugo and markdown. +1 (non-binding) Best, PoAn > On Apr 2, 2025, at 3:01 PM, Bruno Cadonna wrote: > > Thanks a lot for the KIP! > > +1 (binding) > > Best, > Bruno > > On 02.04.25 02:57, Matthias J. Sax wrote: >> +1 (binding) >> On 3/27/25 2:39 AM, T

[jira] [Created] (KAFKA-19075) Include all share group dynamic configs in extractShareGroupConfigMap method in ShareGroupConfig

Chirag Wadhwa created KAFKA-19075: - Summary: Include all share group dynamic configs in extractShareGroupConfigMap method in ShareGroupConfig Key: KAFKA-19075 URL: https://issues.apache.org/jira/browse/KAFKA-19075