[jira] [Created] (KAFKA-16254) Allow MM2 to fully disable offset sync feature

Omnia Ibrahim created KAFKA-16254: - Summary: Allow MM2 to fully disable offset sync feature Key: KAFKA-16254 URL: https://issues.apache.org/jira/browse/KAFKA-16254 Project: Kafka Issue Type:

[jira] [Created] (KAFKA-16256) Update ConsumerConfig to validate use of group.remote.assignor and partition.assignment.strategy based on group.protocol

Kirk True created KAFKA-16256: - Summary: Update ConsumerConfig to validate use of group.remote.assignor and partition.assignment.strategy based on group.protocol Key: KAFKA-16256 URL:

[jira] [Created] (KAFKA-16255) AsyncKafkaConsumer should not use partition.assignment.strategy

Kirk True created KAFKA-16255: - Summary: AsyncKafkaConsumer should not use partition.assignment.strategy Key: KAFKA-16255 URL: https://issues.apache.org/jira/browse/KAFKA-16255 Project: Kafka

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

Hi Andrew, Thanks for the KIP. A few comments below. 1. kafka-configs.sh (incrementalAlterConfigs) allows you to dynamically change the configs. Maybe in this case, we should not allow the user to change `group.type` if it's already set. 2. What's the behaviour after a group transitions into

[Discuss] KIP-1019: Expose method to determine Metric Measurability

Hi, I would like to start discussion of a small KIP which fills a gap in determining Kafka Metric measurability. KIP-1019: Expose method to determine Metric Measurability Regards,

Re: [Discuss] KIP-1019: Expose method to determine Metric Measurability

Hi Apoorv, Thanks for the KIP. Looks like a useful change to tidy up the metrics code. Thanks, Andrew > On 14 Feb 2024, at 14:55, Apoorv Mittal wrote: > > Hi, > I would like to start discussion of a small KIP which fills a gap in > determining Kafka Metric measurability. > > KIP-1019: Expose

Re: [VOTE] 3.7.0 RC4

Hey Stan, Did we ever get system tests results? I can also start a run On Mon, Feb 12, 2024 at 1:06 PM Jakub Scholz wrote: > +1 (non-binding). I used the staged binaries with Scala 2.13 and the staged > Maven artifacts to run my tests. All seems to work fine. Thanks. > > Jakub > > On Fri, Feb

[jira] [Created] (KAFKA-16257) SchemaProjector should be extensible to logical types

Greg Harris created KAFKA-16257: --- Summary: SchemaProjector should be extensible to logical types Key: KAFKA-16257 URL: https://issues.apache.org/jira/browse/KAFKA-16257 Project: Kafka Issue

[jira] [Resolved] (KAFKA-10719) MirrorMaker2 fails to update its runtime configuration

[ https://issues.apache.org/jira/browse/KAFKA-10719?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Harris resolved KAFKA-10719. - Fix Version/s: 3.7.0 3.6.2 Resolution: Fixed > MirrorMaker2 fails to

[jira] [Resolved] (KAFKA-15407) Not able to connect to kafka from the Private NLB from outside the VPC account

[ https://issues.apache.org/jira/browse/KAFKA-15407?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Harris resolved KAFKA-15407. - Resolution: Invalid > Not able to connect to kafka from the Private NLB from outside the VPC >

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

Hi Assane, Thanks for the KIP! Looking back, it appears that the project has only ever added compression types twice: lz4 in 2014 and zstd in 2018, and perhaps Kafka has fallen behind the state-of-the-art compression algorithms. Thanks for working to fix that! I do have some concerns: 1. I

Re: [DISCUSS] KIP-1010: Topic Partition Quota

Thanks Viktor, Hi folks, I would like to propose a new feature to extend the quota management in Kafka to support topic-partition based quotas. The following is the link to the KIP https://cwiki.apache.org/confluence/display/KAFKA/KIP-1010%3A+Topic+Partition+Quota Best, Afshin Moazami On Wed,

Re: [VOTE] 3.7.0 RC4

I just merged a PR to trunk that fixes some of the LogDirFailureTests. I believe the issue is mostly related to the tests and not the code. Not sure if we think it is necessary to hotfix since the change was in the tests.

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

Hi Jun, Thanks for the feedback. Excuse the delay, it took me a while to properly address your detailed feedback. See my comments below. I am going to update the KIP as outlined in this email. I will send another email when I have made all of the changes. On Fri, Feb 2, 2024 at 10:54 AM Jun Rao

Re: [VOTE] 3.7.0 RC4

Hey Justine, Good question. I have been running the system tests and I have been preparing a doc to share. I got one run completed and was waiting for a second one to cross-check, but unfortunately I had a build take 35+ hours and canceled it. I'm currently 6h into the second one, expecting it to

[jira] [Created] (KAFKA-16258) Stale member should trigger onPartitionsLost when leaving group

Lianet Magrans created KAFKA-16258: -- Summary: Stale member should trigger onPartitionsLost when leaving group Key: KAFKA-16258 URL: https://issues.apache.org/jira/browse/KAFKA-16258 Project: Kafka

[jira] [Created] (KAFKA-16259) Immutable MetadataCache to improve client performance

Zhifeng Chen created KAFKA-16259: Summary: Immutable MetadataCache to improve client performance Key: KAFKA-16259 URL: https://issues.apache.org/jira/browse/KAFKA-16259 Project: Kafka Issue

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

Hi Divij, Mickael, Since Mickael KIP-390 was accepted, I did not want to respond in that thread to not confuse the work. As mentioned in the thread, the KIP-390 and KIP-984 do not supercede each other. However the scope of KIP-984 goes beyond the scope of KIP-390. Pluggable compression

[jira] [Created] (KAFKA-16260) Remove window.size.ms from StreamsConfig

Lucia Cerchie created KAFKA-16260: - Summary: Remove window.size.ms from StreamsConfig Key: KAFKA-16260 URL: https://issues.apache.org/jira/browse/KAFKA-16260 Project: Kafka Issue Type:

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

See

[jira] [Resolved] (KAFKA-10735) Kafka producer producing corrupted avro values when confluent cluster is recreated and producer application is not restarted

[ https://issues.apache.org/jira/browse/KAFKA-10735?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Harris resolved KAFKA-10735. - Resolution: Cannot Reproduce Hi, since this doesn't contain any Apache Kafka code, and doesn't

Re: [VOTE] 3.7.0 RC4

+1 (non-binding). I used the staged binaries with Scala 2.13 and mostly focused on the ZooKeeper to KRaft migration with multiple tests. Everything works fine. Thanks Paolo On Mon, 12 Feb 2024, 22:06 Jakub Scholz, wrote: > +1 (non-binding). I used the staged binaries with Scala 2.13 and the

[jira] [Resolved] (KAFKA-16247) replica keep out-of-sync after migrating broker to KRaft

[ https://issues.apache.org/jira/browse/KAFKA-16247?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Chen resolved KAFKA-16247. --- Resolution: Fixed Fixed in 3.7.0 RC4 > replica keep out-of-sync after migrating broker to KRaft >

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

See

[jira] [Created] (KAFKA-16253) kafka_server_alterPartition_metrics_network_io_total is not supported in kafka 3.5.1

Janardhana Gopalachar created KAFKA-16253: - Summary: kafka_server_alterPartition_metrics_network_io_total is not supported in kafka 3.5.1 Key: KAFKA-16253 URL: