[jira] [Created] (KAFKA-17352) Upgrade Gradle Enterprise to develocity plugin

David Arthur created KAFKA-17352: Summary: Upgrade Gradle Enterprise to develocity plugin Key: KAFKA-17352 URL: https://issues.apache.org/jira/browse/KAFKA-17352 Project: Kafka Issue Type: Ta

[jira] [Resolved] (KAFKA-17250) Many system tests failing with org.apache.kafka.common.errors.UnsupportedVersionException: Attempted to write a non-default replicaDirectoryId at version 13

[ https://issues.apache.org/jira/browse/KAFKA-17250?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai resolved KAFKA-17250. Resolution: Duplicate This should be fixed by KAFKA-17276 > Many system tests failing wit

Re: [DISCUSS] KIP-1071: Streams Rebalance Protocol

Hi everyone, Looks really promising, and I can see this resolving several issues I've noticed. I particularly like the choice to use a String for Subtopology ID, as it will (eventually) lead to a better solution to KIP-816. I noticed a few typos in the KIP that I thought I'd mention: NT1. In sev

[jira] [Resolved] (KAFKA-16818) Move event processing-related tests from ConsumerNetworkThreadTest to ApplicationEventProcessorTest

[ https://issues.apache.org/jira/browse/KAFKA-16818?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai resolved KAFKA-16818. Resolution: Fixed > Move event processing-related tests from ConsumerNetworkThreadTest to

[DISCUSS] GitHub CI

Hey everyone, Over the past several months (years, maybe?) I've tinkered around with GitHub Actions as a possible alternative to Jenkins for Apache Kafka CI. I think it is time to actually give it an earnest try. We have already done some work with GH Actions. Namely the Docker build and the "sta

Re: [VOTE] KIP-932: Queues for Kafka

Hi, Andrew, Thanks for the clarification. Sounds good. Jun On Thu, Aug 15, 2024 at 2:53 AM Andrew Schofield wrote: > Hi Jun, > Thanks for the questions. > > 1. The PartitionMetadata is only stored if there is rack ID information. > So, there are situations in which it’s redundant, but almost a

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

See

[jira] [Resolved] (KAFKA-17238) Move VoterSet and ReplicaKey from raft.internals to raft

[ https://issues.apache.org/jira/browse/KAFKA-17238?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai resolved KAFKA-17238. Fix Version/s: 4.0.0 Resolution: Fixed > Move VoterSet and ReplicaKey from raft.int

[jira] [Resolved] (KAFKA-14094) KIP-853: KRaft controller membership changes

[ https://issues.apache.org/jira/browse/KAFKA-14094?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] José Armando García Sancio resolved KAFKA-14094. Resolution: Fixed > KIP-853: KRaft controller membership changes >

[jira] [Resolved] (KAFKA-17318) Introduce ConsumerRecord.deliveryCount()

[ https://issues.apache.org/jira/browse/KAFKA-17318?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai resolved KAFKA-17318. Fix Version/s: 4.0.0 Resolution: Fixed > Introduce ConsumerRecord.deliveryCount() >

[jira] [Created] (KAFKA-17351) Validate compacted topics start offset handling in Share Partition

Apoorv Mittal created KAFKA-17351: - Summary: Validate compacted topics start offset handling in Share Partition Key: KAFKA-17351 URL: https://issues.apache.org/jira/browse/KAFKA-17351 Project: Kafka

[jira] [Created] (KAFKA-17350) Improve kafka-share-groups.sh --describe output for empty groups

Andrew Schofield created KAFKA-17350: Summary: Improve kafka-share-groups.sh --describe output for empty groups Key: KAFKA-17350 URL: https://issues.apache.org/jira/browse/KAFKA-17350 Project: Kaf

[jira] [Created] (KAFKA-17349) Make sure all IT have "quorum" input arguments

Chia-Ping Tsai created KAFKA-17349: -- Summary: Make sure all IT have "quorum" input arguments Key: KAFKA-17349 URL: https://issues.apache.org/jira/browse/KAFKA-17349 Project: Kafka Issue Type

[jira] [Created] (KAFKA-17348) Add ability to specify a custom produce request parser.

Max created KAFKA-17348: --- Summary: Add ability to specify a custom produce request parser. Key: KAFKA-17348 URL: https://issues.apache.org/jira/browse/KAFKA-17348 Project: Kafka Issue Type: New Featur

Re: Contributing to Kafka

Thank you! Created JIRA: https://issues.apache.org/jira/browse/KAFKA-17348 > On Aug 15, 2024, at 10:03 AM, Chia-Ping Tsai wrote: > > hi > > Normally, this kind of issue needs a "JIRA" and a "KIP". That is a rule of > kafka community. > > The jira is used to describe your idea briefly, displa

Re: Contributing to Kafka

hi Normally, this kind of issue needs a "JIRA" and a "KIP". That is a rule of kafka community. The jira is used to describe your idea briefly, display the fix version, and other details. Also, we can keep tech discussion over there. The KIP is used to discuss the public APIs or big changes. Hen

[jira] [Resolved] (KAFKA-16022) AsyncKafkaConsumer sometimes complains “No current assignment for partition {}”

[ https://issues.apache.org/jira/browse/KAFKA-16022?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lianet Magrans resolved KAFKA-16022. Resolution: Done Root cause identified and filed/fixed separately > AsyncKafkaConsumer so

Re: Contributing to Kafka

I have described it in a pull request mentioned in the original email. Pasting below: https://github.com/apache/kafka/pull/16812 Feature/add custom produce request parsers by maxfortun · Pull Request #16812 · apache/kafka github.com Add ability to specify a custom produce request parser. A cust

[jira] [Resolved] (KAFKA-16290) Investigate propagating subscription state updates via queues

[ https://issues.apache.org/jira/browse/KAFKA-16290?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lianet Magrans resolved KAFKA-16290. Assignee: Lianet Magrans Resolution: Fixed > Investigate propagating subscription st

[jira] [Created] (KAFKA-17347) Add omitted --client-metrics option to kafka-configs.sh

Andrew Schofield created KAFKA-17347: Summary: Add omitted --client-metrics option to kafka-configs.sh Key: KAFKA-17347 URL: https://issues.apache.org/jira/browse/KAFKA-17347 Project: Kafka

Contribution to RAT

Greetings, I have been working on Apache RAT recently and I noticed that Kafka has a very nice XSLT to convert the Rat output to an HTML document. I know there is not a legal or licensing issue but I am asking if there are any objections to my taking the .gradle/resources/rat-output-to-html.xsl f

[jira] [Resolved] (KAFKA-17326) The LIST_OFFSET request is removed from the "Api Keys" page

[ https://issues.apache.org/jira/browse/KAFKA-17326?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai resolved KAFKA-17326. Resolution: Fixed > The LIST_OFFSET request is removed from the "Api Keys" page >

[jira] [Created] (KAFKA-17346) Refactor Share Sesssion Class to Server Module

Apoorv Mittal created KAFKA-17346: - Summary: Refactor Share Sesssion Class to Server Module Key: KAFKA-17346 URL: https://issues.apache.org/jira/browse/KAFKA-17346 Project: Kafka Issue Type:

[jira] [Created] (KAFKA-17345) Client nonce is not checked during SASL-SCRAM-256 authentication

Tim Fox created KAFKA-17345: --- Summary: Client nonce is not checked during SASL-SCRAM-256 authentication Key: KAFKA-17345 URL: https://issues.apache.org/jira/browse/KAFKA-17345 Project: Kafka Issue

Re: [DISCUSS] KIP-1071: Streams Rebalance Protocol

Hi Andrew, thanks for the comment. AS12: I clarified the command-line interface. It's supposed to be used with --reset-offsets and --delete-offsets. I removed --topic. AS13: Yes, it's --delete. I clarified the command-line interface. Cheers, Lucas On Tue, Aug 13, 2024 at 4:14 PM Andrew Schofie

Re: [VOTE] KIP-932: Queues for Kafka

Hi Jun, Thanks for the questions. 1. The PartitionMetadata is only stored if there is rack ID information. So, there are situations in which it’s redundant, but almost always the PartitionMetadata will be empty. 2. They are for subtly different purposes. ShareGroupPartitionMetadata is essentially

Re: [DISCUSS] KIP-1073 Return inactive observer nodes in DescribeQuorum response

Hi Colin and Jose, Thanks for taking a look at the KIP and providing feedback. I overlooked that the memory state containing observers will be lost when a controller restarts. You also made a good point about other observers that might be connecting to the quorum to read the current metadata. I a

Re: ACL authorization question

:DOH: Nevermind. Problem between keyboard and seat. On Thu, Aug 15, 2024 at 8:36 AM Claude Warren, Jr wrote: > If there is an authorizer with no ACLs and > authorizeByResourceType(AuthorizableRequestContext > requestContext, AclOperation op, ResourceType resourceType) is called > with op = UN

ACL authorization question

If there is an authorizer with no ACLs and authorizeByResourceType(AuthorizableRequestContext requestContext, AclOperation op, ResourceType resourceType) is called with op = UNKNOWN or ANY, or resourceType = UKNOWN or ANY should an IllegalArgumentException be thrown as it is when there are ACLs? I