Jenkins build is unstable: Kafka » Kafka Branch Builder » trunk #2995

See

Build failed in Jenkins: Kafka » Kafka Branch Builder » 3.7 #176

See Changes: -- [...truncated 461003 lines...] [2024-06-11T01:18:32.255Z] [2024-06-11T01:18:32.255Z] Gradle Test Run :core:test > Gradle Test Executor 95 > ZkMigrationIntegr

[jira] [Resolved] (KAFKA-16924) No log output when running kafka

[ https://issues.apache.org/jira/browse/KAFKA-16924?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Chen resolved KAFKA-16924. --- Resolution: Fixed > No log output when running kafka > - > >

[jira] [Created] (KAFKA-16929) Conside defining kafka-specified assertion to unify testing style

Chia-Ping Tsai created KAFKA-16929: -- Summary: Conside defining kafka-specified assertion to unify testing style Key: KAFKA-16929 URL: https://issues.apache.org/jira/browse/KAFKA-16929 Project: Kafka

Re: [DISCUSS] KIP-1027 Add MockFixedKeyProcessorContext

Shaswhat, any updates on this KIP? -- I still think that recommending to use `InternalFixedKeyRecordFactory` is not the best way to write test code. Changing `FixedKeyRecord` constructor (as I mentioned in my last email) might not be a good solution either. Maybe a cleaner way would be (so s

Re: [DISCUSS] KIP-1049: Add config log.summary.interval.ms to Kafka Streams

Thanks for updating the KIP. Overall LGTM. However, "rejected alternatives" still says: add a new configuration log.summary.interval.ms to control the output interval of summary log This seems not to be rejected, but what the KIP actually proposes and should be removed? I think you can s

Re: [DISCUSS] KIP-655: Add deduplication processor in kafka-streams

Thanks for the update Ayoub. 101: you say: But I am not sure if we don't want to have them for this processor ? What is your reasoning to move off the established pattern? Would be good to understand, why `Deduplicated` class needs a different "structure" compared to existing classes.

Re: [DISCUSS] KIP-1050: Consistent error handling for Transactions

Thanks for this KIP. Great to see it. I would assume it will make KIP-691 unnecessary? I don't think I fully understand the proposal yet. It's clear, that you propose to add new sub-classed to group existing exceptions. But it's not clear to me, which of the existing exceptions (which implemen

Re: [DISCUSS] KIP-1056: Remove `default.` prefix for exception handler StreamsConfig

Thanks for the KIP Murali, Overall LGTM. A few comments. 100: Config names are part of the public interface, and the KIP should not say "none" in this section, but call out which configs are deprecated and which ones are newly added. 101: Nit. In "Propose Changes" there is the template pl

Re: [DISCUSS] KIP-1035: StateStore managed changelog offsets

Thanks Nick. 201: This make sense. Would it make sense to actually document the hard requirement? 202: SG. 204: Ah yes. Thanks for clarifying. 205: SG. I think you can start a VOTE. -Matthias On 6/6/24 2:53 AM, Nick Telford wrote: Hi Matthias, Thanks for your thorough review. 200.

[VOTE] 3.7.1 RC1

Hello Kafka users, developers and client-developers, This is the first candidate for release of Apache Kafka 3.7.1. This is a bugfix release with several fixes. Release notes for the 3.7.1 release: https://home.apache.org/~soarez/kafka-3.7.1-rc1/RELEASE_NOTES.html *** Please download, test and

Jenkins build is still unstable: Kafka » Kafka Branch Builder » 3.8 #29

See

[jira] [Resolved] (KAFKA-14567) Kafka Streams crashes after ProducerFencedException

[ https://issues.apache.org/jira/browse/KAFKA-14567?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-14567. - Assignee: (was: Kirk True) Resolution: Fixed Not 100% sure either, but I feel

[jira] [Resolved] (KAFKA-9228) Reconfigured converters and clients may not be propagated to connector tasks

[ https://issues.apache.org/jira/browse/KAFKA-9228?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton resolved KAFKA-9228. -- Fix Version/s: 3.9.0 Resolution: Fixed > Reconfigured converters and clients may not be

[jira] [Created] (KAFKA-16928) Test all of the request and response methods in RaftUtil

José Armando García Sancio created KAFKA-16928: -- Summary: Test all of the request and response methods in RaftUtil Key: KAFKA-16928 URL: https://issues.apache.org/jira/browse/KAFKA-16928 P

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

See

[jira] [Created] (KAFKA-16927) Adding tests for restarting followers receiving leader endpoint correctly

Alyssa Huang created KAFKA-16927: Summary: Adding tests for restarting followers receiving leader endpoint correctly Key: KAFKA-16927 URL: https://issues.apache.org/jira/browse/KAFKA-16927 Project: Ka

[jira] [Created] (KAFKA-16926) Optimize BeginQuorumEpoch heartbeat

Alyssa Huang created KAFKA-16926: Summary: Optimize BeginQuorumEpoch heartbeat Key: KAFKA-16926 URL: https://issues.apache.org/jira/browse/KAFKA-16926 Project: Kafka Issue Type: Sub-task

Re: [DISCUSS] KIP-1017: A health check endpoint for Kafka Connect

Hi all, Thanks for the positive feedback! I've made one small addition to the KIP since there's been a change to our REST timeout error messages that's worth incorporating here. Quoting the added section directly: > Note that the HTTP status codes and "status" fields in the JSON response will ma

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

See

[jira] [Resolved] (KAFKA-16821) Create a new interface to store member metadata

[ https://issues.apache.org/jira/browse/KAFKA-16821?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Jacot resolved KAFKA-16821. - Fix Version/s: 3.8.0 Resolution: Fixed > Create a new interface to store member metadata

[jira] [Resolved] (KAFKA-14509) Add ConsumerGroupDescribe API

[ https://issues.apache.org/jira/browse/KAFKA-14509?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Jacot resolved KAFKA-14509. - Fix Version/s: 3.8.0 Resolution: Fixed > Add ConsumerGroupDescribe API >

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

+1 (binding), thanks Mickael! On Mon, Jun 10, 2024, 04:24 Mickael Maison wrote: > Hi, > > Following the feedback in the DISCUSS thread, I made significant > changes to the proposal. So I'd like to restart a vote for KIP-877: > > https://cwiki.apache.org/confluence/display/KAFKA/KIP-877%3A+Mechan

[jira] [Created] (KAFKA-16925) stream-table join does not immediately forward expired records on restart

Ayoub Omari created KAFKA-16925: --- Summary: stream-table join does not immediately forward expired records on restart Key: KAFKA-16925 URL: https://issues.apache.org/jira/browse/KAFKA-16925 Project: Kafk

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

Hi, Following the feedback in the DISCUSS thread, I made significant changes to the proposal. So I'd like to restart a vote for KIP-877: https://cwiki.apache.org/confluence/display/KAFKA/KIP-877%3A+Mechanism+for+plugins+and+connectors+to+register+metrics Thanks, Mickael On Thu, Jan 25, 2024 at 2