[jira] [Created] (KAFKA-16318) Add javadoc to KafkaMetric

Mickael Maison created KAFKA-16318: -- Summary: Add javadoc to KafkaMetric Key: KAFKA-16318 URL: https://issues.apache.org/jira/browse/KAFKA-16318 Project: Kafka Issue Type: Bug

[jira] [Resolved] (KAFKA-16071) NPE in testDescribeUnderReplicatedPartitionsWhenReassignmentIsInProgress

[ https://issues.apache.org/jira/browse/KAFKA-16071?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Chen resolved KAFKA-16071. --- Resolution: Fixed > NPE in testDescribeUnderReplicatedPartitionsWhenReassignmentIsInProgress >

[jira] [Created] (KAFKA-16320) CreateTopics, DeleteTopics and CreatePartitions differences between Zookeeper and KRaft

Emanuele Sabellico created KAFKA-16320: -- Summary: CreateTopics, DeleteTopics and CreatePartitions differences between Zookeeper and KRaft Key: KAFKA-16320 URL:

Re: [DISCUSS] KIP-853: KRaft Controller Membership Changes

Hi Jun, Thanks for the feedback. See my comments below. On Tue, Feb 27, 2024 at 11:27 AM Jun Rao wrote: > 30. Who controls RPCs like Fetch, FetchSnapshot, DescribeQuorum RPC? They > are shared between voters and observers. For Fetch and FetchSnapshot, this KIP adds the tagged field ReplicaUuid

Re: [DISCUSS] KIP-853: KRaft Controller Membership Changes

Hi, Jose, Thanks for the reply. 30. Historically, we used MV to gate the version of Fetch request. Are you saying that voters will ignore MV and only depend on raft.version when choosing the version of Fetch request? 35. Upgrading the controller listeners. 35.1 So, the protocol is that each

Assistance Needed: Community Over Code Connections

Good day, As we approach the season of ASF events, we are seeking assistance from some Apache PMC committers to discover contact information for the various organizations that use and contribute to those projects, in the hopes of partnering with them on event sponsorship. This will help make

[jira] [Created] (KAFKA-16319) Wrong broker destinations for DeleteRecords requests when more than one topic is involved and the topics/partitions are led by different brokers

AlexeyASF created KAFKA-16319: - Summary: Wrong broker destinations for DeleteRecords requests when more than one topic is involved and the topics/partitions are led by different brokers Key: KAFKA-16319 URL:

Requesting permissions to contribute to Apache Kafka.

Hi team, I would like permission to contribute to Kafka. My wiki ID is "d.gasparina" and my Jira ID is "Dabz". I would like to propose a KIP to improve Kafka Streams error and exception handling. Cheers, Damien

Re: [VOTE] 3.7.0 RC4

Makes sense, thanks Ismael. I've updated it. We are released now! Thank you to all who contributed! There are two final things to do with relation to the release as per the wiki - and that is introduce 3.7 to the respective compatibility system tests for Core, Clients and Streams. Here are the

Re: Requesting permissions to contribute to Apache Kafka.

Hi Damien, I've granted you permissions in both Jira and Confluence. Thanks, Mickael On Fri, Mar 1, 2024 at 2:43 PM Damien Gasparina wrote: > > Hi team, > > I would like permission to contribute to Kafka. > My wiki ID is "d.gasparina" and my Jira ID is "Dabz". > > I would like to propose a KIP

Jenkins build is still unstable: Kafka » Kafka Branch Builder » trunk #2688

See

Jenkins build is still unstable: Kafka » Kafka Branch Builder » trunk #2689

See

Re: [DISCUSS] KIP-853: KRaft Controller Membership Changes

Hi Luke, Thanks for the feedback. See my comments below. I have also updated the KIP to reflect this discussion. On Wed, Feb 28, 2024 at 4:34 AM Luke Chen wrote: > > > 2. After "RemoveVoter", what is the role of the node? > > It looks like after the voter got removed from the voter set, it is

Re: [DISCUSS] KIP-1020: Deprecate `window.size.ms` in `StreamsConfig`

One more thought after I did some more digging on the related PR. Should we do the same thing for `windowed.inner.serde.class`? Both config belong to windowed serdes (which KS provide) but the KS code itself does never use them (and in fact, disallows to use them and would throw an error is

Re: [DISCUSS] KIP-1022 Formatting and Updating Features

Hi, Justine, Thanks for the reply. 11. Yes, we can still have the option to set individual features. I was suggesting that if one uses the tool without either --release-version or --features, it will just use the latest version of every feature that it knows. This is what's proposed in the

Re: [DISCUSS] KIP-939: Support Participation in 2PC

Hi Jun, > 32. ... metric name ... I've updated the metric name to be *kafka.coordinator.transaction:type=TransactionStateManager,name=ActiveTransactionOpenTimeMax.* Let me know if it works. -Artem On Thu, Feb 29, 2024 at 12:03 PM Artem Livshits wrote: > Hi Jun, > > > So, it doesn't

Re: [DISCUSS] KIP-1024: Make the restore behavior of GlobalKTables with custom processors configureable

Thanks for the KIP Walker. Fixing this issue, and providing users some flexibility to opt-in/out on "restore reprocessing" is certainly a good improvement. From an API design POV, I like the idea to not require passing in a ProcessorSupplier to begin with. Given the current implementation of

RE: DISCUSS KIP-984 Add pluggable compression interface to Kafka

Hi Luke, The proposal doesn't preclude supporting multiple clients but each client would need an implementation of the pluggable architecture. At the very least we envision other clients such as librdkafka and kafka-python could be supported by C implementations. We agree with community

[jira] [Created] (KAFKA-16321) Default directory ids to MIGRATING, not UNASSIGNED

Colin McCabe created KAFKA-16321: Summary: Default directory ids to MIGRATING, not UNASSIGNED Key: KAFKA-16321 URL: https://issues.apache.org/jira/browse/KAFKA-16321 Project: Kafka Issue

Jenkins build is still unstable: Kafka » Kafka Branch Builder » trunk #2690

See