[jira] [Created] (KAFKA-16196) Cast transform doesn't handle invalid whole value casts gracefully

2024-01-25 Thread Yash Mayya (Jira)
Yash Mayya created KAFKA-16196: -- Summary: Cast transform doesn't handle invalid whole value casts gracefully Key: KAFKA-16196 URL: https://issues.apache.org/jira/browse/KAFKA-16196 Project: Kafka

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

2024-01-25 Thread José Armando García Sancio
Hi all, I have updated the KIP to include information on how KRaft controller automatic joining will work. Thanks, -- -José

Re: Kafka trunk test & build stability

2024-01-25 Thread Justine Olshan
It looks like there was some server maintenance that shut down Jenkins. Upon coming back up, the builds were expired but unable to stop. They all had similar logs: Cancelling nested steps due to timeoutCancelling nested steps due to timeoutBody did not finish within grace period; terminating

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

2024-01-25 Thread José Armando García Sancio
Hi Jason, Colin and Luke, I updated the KIP based on your feedback and my comments. Here is what has changed: https://cwiki.apache.org/confluence/pages/diffpagesbyversion.action?pageId=217391519=54=52 Here is an outline of all of the protocol changes: 1. Removed the AddVoterRecord and

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

2024-01-25 Thread Jun Rao
Hi, Artem, Thanks for the reply. A few more comments. 20. I am a bit confused by how we set keepPreparedTxn. From the KIP, I got the following (1) to start 2pc, we call InitProducerId(keepPreparedTxn=false); (2) when the producer fails and needs to do recovery, it calls

Re: Kafka trunk test & build stability

2024-01-25 Thread Justine Olshan
Hey folks -- I noticed some builds have been running for a day or more. I thought we limited builds to 8 hours. Any ideas why this is happening? https://ci-builds.apache.org/blue/organizations/jenkins/Kafka%2Fkafka-pr/activity/ I tried to abort the build for PR-15257, and it also still seems to

Re: [DISCUSS] KIP-877: Mechanism for plugins and connectors to register metrics

2024-01-25 Thread Mickael Maison
Hi Luke, The reason vary for each plugin, I've added details to most plugins in the table. The plugins without an explanation are all from Streams. I admit I don't know these interfaces enough to decide if it makes sense making them closeable and instrumenting them. It would be nice to get some

Re: [DISCUSS] KIP-877: Mechanism for plugins and connectors to register metrics

2024-01-25 Thread Mickael Maison
Hi Tom, Thanks for taking a look at the KIP! 1. Yes I considered several names (see the previous messages in the discussion). KIP-608, which this KIP superseeds, used "monitor()" for the method name. I find "withMetrics()" to be nicer due to the way the method should be used. That said, I'm not

[jira] [Resolved] (KAFKA-16003) The znode /config/topics is not updated during KRaft migration in "dual-write" mode

2024-01-25 Thread Mickael Maison (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16003?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mickael Maison resolved KAFKA-16003. Fix Version/s: 3.8.0 Resolution: Fixed > The znode /config/topics is not updated

[jira] [Created] (KAFKA-16195) metadata.log.dir failure shouldn't shutdown broker in ZK mode

2024-01-25 Thread Gaurav Narula (Jira)
Gaurav Narula created KAFKA-16195: - Summary: metadata.log.dir failure shouldn't shutdown broker in ZK mode Key: KAFKA-16195 URL: https://issues.apache.org/jira/browse/KAFKA-16195 Project: Kafka

[jira] [Created] (KAFKA-16194) KafkaConsumer.groupMetadata() should be correct when first records are returned

2024-01-25 Thread David Jacot (Jira)
David Jacot created KAFKA-16194: --- Summary: KafkaConsumer.groupMetadata() should be correct when first records are returned Key: KAFKA-16194 URL: https://issues.apache.org/jira/browse/KAFKA-16194

Re: [DISCUSS] KIP-877: Mechanism for plugins and connectors to register metrics

2024-01-25 Thread Luke Chen
Hi Mickael, Thanks for the KIP. The motivation and solution makes sense to me. Just one question: If we could extend `closable` for Converter plugin, why don't we do that for the "Unsupported Plugins" without close method? I don't say we must do that in this KIP, but maybe you could add the

[jira] [Resolved] (KAFKA-7957) Flaky Test DynamicBrokerReconfigurationTest#testMetricsReporterUpdate

2024-01-25 Thread Mickael Maison (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-7957?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mickael Maison resolved KAFKA-7957. --- Resolution: Fixed > Flaky Test DynamicBrokerReconfigurationTest#testMetricsReporterUpdate >

Re: [VOTE] KIP-1011: Use incrementalAlterConfigs when updating broker configs by kafka-configs.sh

2024-01-25 Thread ziming deng
The KIP is accepted with 4 binding votes (Chirs, Divij Vaidya, David and Luke) and 4 unbinding votes(Kamal, Federico, Andrew and Николай Ижиков). Thank you all ! > On Jan 24, 2024, at 20:44, Николай Ижиков wrote: > > +1 (non-binding) > >> 24 янв. 2024 г., в 12:48, Chris Egerton написал(а):