[jira] [Created] (KAFKA-19144) Move DelayedProduce to server module

Chia-Ping Tsai created KAFKA-19144: -- Summary: Move DelayedProduce to server module Key: KAFKA-19144 URL: https://issues.apache.org/jira/browse/KAFKA-19144 Project: Kafka Issue Type: Sub-task

[jira] [Created] (KAFKA-19146) Merge org.apache.kafka.server.common.OffsetAndEpoch and org.apache.kafka.raft.OffsetAndEpoch

Chia-Ping Tsai created KAFKA-19146: -- Summary: Merge org.apache.kafka.server.common.OffsetAndEpoch and org.apache.kafka.raft.OffsetAndEpoch Key: KAFKA-19146 URL: https://issues.apache.org/jira/browse/KAFKA-19146

[DISCUSS] KIP-1160: Enable returning supported features from a specific broker

Hi all, I would like to start a discussion thread on KIP-1160. It adds node id to DescribeFeaturesOptions, so Admin client and kafka-features have ability to retrieve features from a specific node. Please take a look and feel free to share any thought. https://cwiki.apache.org/confluence/x/5gnX

[jira] [Created] (KAFKA-19147) ConsumerGroupHeartbeat API leaks topic id and partition count of unauthorized topics

Rajini Sivaram created KAFKA-19147: -- Summary: ConsumerGroupHeartbeat API leaks topic id and partition count of unauthorized topics Key: KAFKA-19147 URL: https://issues.apache.org/jira/browse/KAFKA-19147

[jira] [Created] (KAFKA-19148) Potential Unclean Leader Election in KRaft Despite unclean.leader.election.enable=false

Julian Bergner created KAFKA-19148: -- Summary: Potential Unclean Leader Election in KRaft Despite unclean.leader.election.enable=false Key: KAFKA-19148 URL: https://issues.apache.org/jira/browse/KAFKA-19148

Re: [DISCUSS] KIP-1139: Add support for OAuth jwt-bearer grant type

Hi Jun! I really appreciate your feedback. Responses below... On Fri, Apr 11, 2025, at 1:47 PM, Jun Rao wrote: > Hi, Kirk, > > Thanks for the KIP. A few comments below. > > JR1. OAuthBearerConfigurable.configure(): Could you describe the possible > values for saslMechanism? Is it always OAUTHB

[jira] [Resolved] (KAFKA-18888) Add support for Authorizer

[ https://issues.apache.org/jira/browse/KAFKA-1?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mickael Maison resolved KAFKA-1. Fix Version/s: 4.1.0 Resolution: Fixed > Add support for Authorizer > -

Re: [DISCUSS] KIP-1139: Add support for OAuth jwt-bearer grant type

Hi Lianet! Thank you for your feedback! My responses are inline below... On Fri, Apr 11, 2025, at 1:16 PM, Lianet M. wrote: > Hi Kirk, thanks for the KIP! Some questions and comments from a first pass: > > LM1. There are several new classes proposed that are just based on existing > classes. I

Re: [DISCUSS] KIP-1139: Add support for OAuth jwt-bearer grant type

Hi Manikumar! Thanks for your feedback! Comments below... On Thu, Apr 10, 2025, at 2:04 AM, Manikumar wrote: > Hi Kirk, > > Thanks for the KIP. This will be a valuable addition for implementing the > JWT Bearer Grant Type in OAuth 2.0 authorization flow. > > I had a few comments and suggestion

[jira] [Created] (KAFKA-19153) Add OAuth integration tests using Keycloak

Kirk True created KAFKA-19153: - Summary: Add OAuth integration tests using Keycloak Key: KAFKA-19153 URL: https://issues.apache.org/jira/browse/KAFKA-19153 Project: Kafka Issue Type: Improvement

[jira] [Created] (KAFKA-19152) Add top-level documentation for OAuth flows

Kirk True created KAFKA-19152: - Summary: Add top-level documentation for OAuth flows Key: KAFKA-19152 URL: https://issues.apache.org/jira/browse/KAFKA-19152 Project: Kafka Issue Type: Improvement

[jira] [Created] (KAFKA-19154) Return INVALID_OFFSET if requested topic id does not match persisted one

David Jacot created KAFKA-19154: --- Summary: Return INVALID_OFFSET if requested topic id does not match persisted one Key: KAFKA-19154 URL: https://issues.apache.org/jira/browse/KAFKA-19154 Project: Kafka

[DISCUSS] KIP-1161: cleanup.policy shouldn't be empty

Hello everyone, I would like to start a discussion on KIP-1161: cleanup.policy shouldn't be empty This proposal aims to improve the cleanup.policy configuration. Currently, this setting should not be left empty. Therefore, there are two proposed i

[jira] [Resolved] (KAFKA-18845) Fail test QuorumControllerTest#testUncleanShutdownBrokerElrEnabled

[ https://issues.apache.org/jira/browse/KAFKA-18845?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai resolved KAFKA-18845. Fix Version/s: 4.1.0 Resolution: Fixed > Fail test QuorumControllerTest#testUnclean

Re: Kafka tags on repo

Hi Jamie, All of our release tags are published to the apache/kafka GitHub repo. You can find them here https://github.com/apache/kafka/tags If you have cloned the apache/kafka GitHub repo, you can do "git fetch --tags" to pull down references for the tags. After that, you can checkout whichever

[jira] [Created] (KAFKA-19140) ConnectAssignor#performAssignment second parameter can be replace from String to ConnectProtocolCompatibility

黃竣陽 created KAFKA-19140: --- Summary: ConnectAssignor#performAssignment second parameter can be replace from String to ConnectProtocolCompatibility Key: KAFKA-19140 URL: https://issues.apache.org/jira/browse/KAFKA-19140

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

See

[jira] [Resolved] (KAFKA-18983) Ensure all README.md(s) are mentioned by the root README.md

[ https://issues.apache.org/jira/browse/KAFKA-18983?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai resolved KAFKA-18983. Fix Version/s: 4.1.0 Resolution: Fixed > Ensure all README.md(s) are mentioned by t

[jira] [Resolved] (KAFKA-19043) Move DelayedRemoteListOffsets to the storage module

[ https://issues.apache.org/jira/browse/KAFKA-19043?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma resolved KAFKA-19043. - Fix Version/s: 4.1.0 Resolution: Fixed Looks like this was done via https://github.com/ap

Re: [DISCUSS] KIP-1101: Trigger rebalance on rack topology changes

Hi PoAn, from my side, we are good to move to a vote on this one. Cheers, Lucas On Thu, Apr 10, 2025 at 11:29 AM PoAn Yang wrote: > > Hi David and Lucas, > > Thanks for the review and great suggestion. > > DJ01: Add the statement about rack-aware rebalance was removed in 4.0. > > DJ02: Change C

[jira] [Resolved] (KAFKA-19061) Add ACL changes to enable role based 2PC

[ https://issues.apache.org/jira/browse/KAFKA-19061?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ritika Reddy resolved KAFKA-19061. -- Resolution: Fixed > Add ACL changes to enable role based 2PC > ---

[jira] [Resolved] (KAFKA-18900) Create a consumer config to select between implicit and explicit acknowledgement

[ https://issues.apache.org/jira/browse/KAFKA-18900?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrew Schofield resolved KAFKA-18900. -- Resolution: Fixed > Create a consumer config to select between implicit and explicit

[jira] [Created] (KAFKA-19150) Consider renaming org.apache.kafka.storage.internals.log.RemoteStorageThreadPool metrics

Mickael Maison created KAFKA-19150: -- Summary: Consider renaming org.apache.kafka.storage.internals.log.RemoteStorageThreadPool metrics Key: KAFKA-19150 URL: https://issues.apache.org/jira/browse/KAFKA-19150

[jira] [Created] (KAFKA-19149) Use KIP-877 in MirrorMaker

Mickael Maison created KAFKA-19149: -- Summary: Use KIP-877 in MirrorMaker Key: KAFKA-19149 URL: https://issues.apache.org/jira/browse/KAFKA-19149 Project: Kafka Issue Type: Improvement

[jira] [Created] (KAFKA-19151) Enhance the docs of flush.ms by reminding users the flush is triggered by log.flush.scheduler.interval.ms

Chia-Ping Tsai created KAFKA-19151: -- Summary: Enhance the docs of flush.ms by reminding users the flush is triggered by log.flush.scheduler.interval.ms Key: KAFKA-19151 URL: https://issues.apache.org/jira/browse/

Re: [DISCUSS] Apache Kafka 4.1.0 release

Hi Mickael, Thoughts on my message below? Ismael On Thu, Apr 10, 2025, 7:46 AM Ismael Juma wrote: > Hi Mickael, > > The release plan indicates a release in August. However, 4.0 was released > on March 18. If we stick to the 4 months schedule, the target release > should be mid July. Is there a

[jira] [Resolved] (KAFKA-18172) Move RemoteIndexCacheTest to storage module

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

[jira] [Created] (KAFKA-19143) Setup periodic job to clean share group deleting metadata state in GC

Sushant Mahajan created KAFKA-19143: --- Summary: Setup periodic job to clean share group deleting metadata state in GC Key: KAFKA-19143 URL: https://issues.apache.org/jira/browse/KAFKA-19143 Project:

Re: [VOTE] KIP-1131: Improved controller-side monitoring of broker states

+1 non binding Thanks On Tue, Mar 25, 2025 at 11:29 PM Kevin Wu wrote: > > Hello all, > > I am manually bumping this thread. > Any feedback or votes would be appreciated. > > Best regards, > Kevin Wu > > On Thu, Mar 13, 2025 at 1:54 PM Kevin Wu wrote: > > > Hello all, > > > > I would like to ca

Kafka tags on repo

Hi All, I was looking to check out Kafka 3.9.0 and 4.0.0 from the public repo, and discovered that those tags are not on the repo. Which repo should one be looking for to pick up the code by tag? https://github.com/apache/kafka/tree/4.0.0 https://github.com/apache/kafka/tree/3.9.0 Cheers, Jamie

[jira] [Created] (KAFKA-19141) Persist topic id in OffsetCommitValue

David Jacot created KAFKA-19141: --- Summary: Persist topic id in OffsetCommitValue Key: KAFKA-19141 URL: https://issues.apache.org/jira/browse/KAFKA-19141 Project: Kafka Issue Type: Sub-task

Re: [DISCUSS] KIP-1101: Trigger rebalance on rack topology changes

Hi Lucas, Thank you. Here is vote thread https://lists.apache.org/thread/j90htmphjk783p697jjfg1xt8thmy33p. Regards, PoAn > On Apr 16, 2025, at 12:07 AM, Lucas Brutschy > wrote: > > Hi PoAn, > > from my side, we are good to move to a vote on this one. > > Cheers, > Lucas > > On Thu, Apr 10

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

See

[jira] [Resolved] (KAFKA-19137) Use `StandardCharsets.UTF_8` instead of `StandardCharsets.UTF_8.name()`

[ https://issues.apache.org/jira/browse/KAFKA-19137?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai resolved KAFKA-19137. Fix Version/s: 4.1.0 Resolution: Fixed > Use `StandardCharsets.UTF_8` instead of `S

Re: [DISCUSS] KIP-1131: Controller-side monitoring for broker shutdown and startup

Hi Colin and Kevin, On Mon, Apr 14, 2025 at 5:25 PM Colin McCabe wrote: > How about something like this? > 10 = fenced > 20 = controlled shutdown > 30 = active Very few users are going to know what these values mean. For example, I see myself having to look up the code and KIP to remember

[jira] [Created] (KAFKA-19145) Move LeaderEndPoint to server module

Chia-Ping Tsai created KAFKA-19145: -- Summary: Move LeaderEndPoint to server module Key: KAFKA-19145 URL: https://issues.apache.org/jira/browse/KAFKA-19145 Project: Kafka Issue Type: Sub-task

[jira] [Resolved] (KAFKA-18902) Implement ShareConsumer option to throw on poll if there are unacked records

[ https://issues.apache.org/jira/browse/KAFKA-18902?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrew Schofield resolved KAFKA-18902. -- Resolution: Fixed > Implement ShareConsumer option to throw on poll if there are unack

Re: [DISCUSS] KIP-1158: Improve Connect SourceTask commit()

Thanks Chris ! I've updated the KIP and added a note in Javadocs, as you suggested. If everything looks good, should I go ahead and start a voting thread ? Thanks again, Sudesh On Tue, 8 Apr 2025 at 21:47, Chris Egerton wrote: > Consistent behavior sounds good to me! We should probably add a no