[jira] [Created] (KAFKA-19695) Last redundant offset calculation to take deleted share partitions into account.

Sushant Mahajan created KAFKA-19695: --- Summary: Last redundant offset calculation to take deleted share partitions into account. Key: KAFKA-19695 URL: https://issues.apache.org/jira/browse/KAFKA-19695

RE: Re: [VOTE] KIP-1209: Add configuration to control internal topic creation in Kafka Connect

Hi, +1 (non-binding) Thanks for the KIP Best regards, Andrei Rudkouski On 2025/09/09 09:07:14 Anton Liauchuk wrote: > hi > > I’ve added an integration test for this new config: > https://github.com/apache/kafka/pull/20384/files#diff-0f86ed224068b85289d9214ae1dad88865d159b8e3658a4231544de36f4

[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 ] Kirk True resolved KAFKA-14567. --- Resolution: Cannot Reproduce We have not been able to reproduce this in our internal test environmen

[jira] [Resolved] (KAFKA-19675) StreamsOnTasksAssignedCallbackNeededEvent could not be completed

[ https://issues.apache.org/jira/browse/KAFKA-19675?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lucas Brutschy resolved KAFKA-19675. Resolution: Won't Fix > StreamsOnTasksAssignedCallbackNeededEvent could not be completed

[DISCUSS] KIP-1216: Add rebalance listener metrics for Kafka Streams

Hi, I'd like to start a discussion on KIP-1216:https://cwiki.apache.org/confluence/display/KAFKA/KIP-1216%3A+Add+rebalance+listener+metrics+for+Kafka+Streams This KIP proposes adding latency metrics for each rebalance callback to provide operators with the observability needed to effectively moni

[DISCUSS] KIP-1218: Expose consumer CorruptRecordException

Hello All, I'd like to start a discussion for KIP-1218. https://cwiki.apache.org/confluence/x/NQrxFg This proposal aims to expose the CorruptRecordException directly from the consumer when a corrupted record is found on the broker. Currently, a generic KafkaException is thrown, which prevents cli

[jira] [Resolved] (KAFKA-19660) JoinWithIncompleteMetadataIntegrationTest fails in isolated run of one parameter

[ https://issues.apache.org/jira/browse/KAFKA-19660?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] travis resolved KAFKA-19660. Reviewer: Lucas Brutschy Resolution: Fixed > JoinWithIncompleteMetadataIntegrationTest fails in isol

[jira] [Resolved] (KAFKA-19083) Fix flaky MetricsDuringTopicCreationDeletionTest. testMetricsDuringTopicCreateDelete(String).quorum=kraft

[ https://issues.apache.org/jira/browse/KAFKA-19083?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] 黃竣陽 resolved KAFKA-19083. - Resolution: Won't Fix > Fix flaky MetricsDuringTopicCreationDeletionTest. > testMetricsDuringTopicCreateDelete(

[jira] [Created] (KAFKA-19696) Re-enable SmokeTestDriverIntegrationTest for processing threads

Lucas Brutschy created KAFKA-19696: -- Summary: Re-enable SmokeTestDriverIntegrationTest for processing threads Key: KAFKA-19696 URL: https://issues.apache.org/jira/browse/KAFKA-19696 Project: Kafka

[jira] [Resolved] (KAFKA-18708) Move ScramPublisher to metadata module

[ https://issues.apache.org/jira/browse/KAFKA-18708?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mickael Maison resolved KAFKA-18708. Fix Version/s: 4.2.0 Resolution: Fixed > Move ScramPublisher to metadata module > -

Re: [DISCUSS] KIP-1217: Include push interval in ClientTelemetryReceiver context

Hi Andrew, Thanks for taking a look! Yeah after experimenting with the approach now listed in the rejected alternatives, I thought it was better to just bring whole new interfaces. AS1: I was following the naming from ClientTelemetry, but I agree it's probably simpler to name that method clientTe

[jira] [Resolved] (KAFKA-19693) Introduce PersisterBatch in SharePartition

[ https://issues.apache.org/jira/browse/KAFKA-19693?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Apoorv Mittal resolved KAFKA-19693. --- Fix Version/s: 4.2.0 Resolution: Fixed > Introduce PersisterBatch in SharePartition >