Re: [VOTE] 3.8.0 RC1

Thanks Greg for taking a look and providing a fix! Best, -- Josep Prat Open Source Engineering Director, Aiven josep.p...@aiven.io | +491715557497 | aiven.io Aiven Deutschland GmbH Alexanderufer 3-7, 10117 Berlin Geschäftsführer: Oskari Saarenmaa & Hannu Valtonen Amtsgericht C

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

See

[jira] [Resolved] (KAFKA-16383) fix flaky test IdentityReplicationIntegrationTest.testReplicateFromLatest()

[ https://issues.apache.org/jira/browse/KAFKA-16383?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton resolved KAFKA-16383. --- Resolution: Fixed > fix flaky test IdentityReplicationIntegrationTest.testReplicateFromLates

[jira] [Created] (KAFKA-17153) KafkaMetricsGroup#newGauge should accept functional interface instead of `com.yammer.metrics.core.Gague`

Chia-Ping Tsai created KAFKA-17153: -- Summary: KafkaMetricsGroup#newGauge should accept functional interface instead of `com.yammer.metrics.core.Gague` Key: KAFKA-17153 URL: https://issues.apache.org/jira/browse/K

Re: [VOTE] 3.8.0 RC1

Hi Josep, I found this blocker regression: https://issues.apache.org/jira/browse/KAFKA-17150 Summary: Connector configurations that specified converters with aliases (e.g. JsonConverter instead of org.apache.kafka.connect.json.JsonConverter) previously worked, and in this RC they throw validation

[jira] [Created] (KAFKA-17152) Make sure zk session tracker gets down when closing embedded zk

Chia-Ping Tsai created KAFKA-17152: -- Summary: Make sure zk session tracker gets down when closing embedded zk Key: KAFKA-17152 URL: https://issues.apache.org/jira/browse/KAFKA-17152 Project: Kafka

[jira] [Created] (KAFKA-17151) Remove waitForCondition when detecting thread leak

Chia-Ping Tsai created KAFKA-17151: -- Summary: Remove waitForCondition when detecting thread leak Key: KAFKA-17151 URL: https://issues.apache.org/jira/browse/KAFKA-17151 Project: Kafka Issue

[jira] [Created] (KAFKA-17150) Connect converter validation does not accept class aliases

Greg Harris created KAFKA-17150: --- Summary: Connect converter validation does not accept class aliases Key: KAFKA-17150 URL: https://issues.apache.org/jira/browse/KAFKA-17150 Project: Kafka Issu

Re: [VOTE] 3.8.0 RC1

+1 (non-binding). I used the staged Scala 2.13 binaries and the staged Maven artifacts. All seems to work fine. Thanks! Jakub On Mon, Jul 15, 2024 at 5:53 PM Josep Prat wrote: > Hello Kafka users, developers and client-developers, > > This is the second release candidate for Apache Kafka 3.8.0.

Re: [DISCUSS] KIP-1043: Administration of groups

Hello Andrew, thanks for considering the feedback. Some follow-ups and other comments: LM4. Good point about the older RPC versions and therefore the Optional, agreed. LM5. In GroupListing, should we use the existing org.apache.kafka.clients.ProtocolType to represent the protocol (instead of Stri

[jira] [Resolved] (KAFKA-17017) AsyncConsumer#unsubscribe does not clean the assigned partitions

[ https://issues.apache.org/jira/browse/KAFKA-17017?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai resolved KAFKA-17017. Fix Version/s: 3.9.0 Resolution: Fixed > AsyncConsumer#unsubscribe does not clean t

[jira] [Created] (KAFKA-17149) Move ProducerStateManagerTest to storage module

Chia-Ping Tsai created KAFKA-17149: -- Summary: Move ProducerStateManagerTest to storage module Key: KAFKA-17149 URL: https://issues.apache.org/jira/browse/KAFKA-17149 Project: Kafka Issue Typ

Re: [DISCUSS] KIP-950: Tiered Storage Disablement

Hello! Makes sense thank you for pointing it out, I will aim to update the section. I also need to add to the section for metrics! Best, Christo On Mon, 15 Jul 2024 at 19:45, Jun Rao wrote: > Hi, Christo, > > Thanks for the KIP and sorry for the late reply. > > Since this KIP changes the forma

[jira] [Created] (KAFKA-17148) Kafka storage tool prints MetadataPropertiesEnsemble

Greg Harris created KAFKA-17148: --- Summary: Kafka storage tool prints MetadataPropertiesEnsemble Key: KAFKA-17148 URL: https://issues.apache.org/jira/browse/KAFKA-17148 Project: Kafka Issue Type

[jira] [Created] (KAFKA-17147) Improve KRaft add voter handling to tolerate waiting for delayed operations

José Armando García Sancio created KAFKA-17147: -- Summary: Improve KRaft add voter handling to tolerate waiting for delayed operations Key: KAFKA-17147 URL: https://issues.apache.org/jira/browse/KAFKA-

[jira] [Resolved] (KAFKA-17055) Use random replica ids in KafkaRaftClientTest and KafkaRaftClientSnapshotTest

[ https://issues.apache.org/jira/browse/KAFKA-17055?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] José Armando García Sancio resolved KAFKA-17055. Resolution: Fixed > Use random replica ids in KafkaRaftClientTest

[jira] [Resolved] (KAFKA-17145) Reinstate Utils.join() method in org.apache.kafka.common.utils

[ https://issues.apache.org/jira/browse/KAFKA-17145?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton resolved KAFKA-17145. --- Resolution: Won't Fix > Reinstate Utils.join() method in org.apache.kafka.common.utils > ---

[jira] [Created] (KAFKA-17146) ZK to KRAFT migration stuck in pre-migration mode

Simone Brundu created KAFKA-17146: - Summary: ZK to KRAFT migration stuck in pre-migration mode Key: KAFKA-17146 URL: https://issues.apache.org/jira/browse/KAFKA-17146 Project: Kafka Issue Typ

Re: [DISCUSS] KIP-1068: KIP-1068: New JMX Metrics for AsyncKafkaConsumer

Hi Andrew, Thank you for your reply. AS4. Adding '.ms' was a suggestion that was brought up but not required in any way. After going back and looking at our current set of metrics, specifically for the consumer, it seems that only metrics measured in nanoseconds include its unit in the metric name

[jira] [Created] (KAFKA-17145) Reinstate Utils.join() method in org.apache.kafka.common.utils

Vikas Balani created KAFKA-17145: Summary: Reinstate Utils.join() method in org.apache.kafka.common.utils Key: KAFKA-17145 URL: https://issues.apache.org/jira/browse/KAFKA-17145 Project: Kafka

[jira] [Created] (KAFKA-17144) Retract v6 of ListGroups RPC added in error

Andrew Schofield created KAFKA-17144: Summary: Retract v6 of ListGroups RPC added in error Key: KAFKA-17144 URL: https://issues.apache.org/jira/browse/KAFKA-17144 Project: Kafka Issue Typ

Re: [PR] MINOR: document how we deal with advisories for dependencies [kafka-site]

divijvaidya commented on PR #554: URL: https://github.com/apache/kafka-site/pull/554#issuecomment-2230721857 I feel comfortable with the current wording on this PR. Will keep this open for another 3 days for others to chime in, else I will merge this one. -- This is an automated message f

Re: [PR] Add blog post for 3.8 release [kafka-site]

jlprat commented on PR #614: URL: https://github.com/apache/kafka-site/pull/614#issuecomment-2230682910 The contributors list (and number) seems high, but I double checked the list and removed duplicates. This is the command I run: ``` git shortlog -sn --group=author --group=trailer

[jira] [Resolved] (KAFKA-16986) After upgrading to Kafka 3.4.1, the producer constantly produces logs related to topicId changes

[ https://issues.apache.org/jira/browse/KAFKA-16986?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vinicius Vieira dos Santos resolved KAFKA-16986. Resolution: Fixed > After upgrading to Kafka 3.4.1, the producer c

Re: [kafka-clients] [VOTE] 3.8.0 RC1

Hi Josep, Thanks for running this release. +1 non-binding. I performed the following checks: - Verified signatures and checksums - Built from source - Basic workload against a KRaft cluster using the artifacts for both Scala versions - Browsed Javadoc - Checked LICENSE Best, -- Igor

[jira] [Resolved] (KAFKA-16730) Initial code for share-group consumer

[ https://issues.apache.org/jira/browse/KAFKA-16730?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrew Schofield resolved KAFKA-16730. -- Resolution: Fixed > Initial code for share-group consumer > --

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

See

[jira] [Created] (KAFKA-17143) Error while deleting segments and java.nio.file.NoSuchFileException

Prem Kumar created KAFKA-17143: -- Summary: Error while deleting segments and java.nio.file.NoSuchFileException Key: KAFKA-17143 URL: https://issues.apache.org/jira/browse/KAFKA-17143 Project: Kafka

[PR] Add blog post for 3.8 release [kafka-site]

jlprat opened a new pull request, #614: URL: https://github.com/apache/kafka-site/pull/614  -- This is an automated message from the Apache Git Service. To respond to the message, please log on to

[jira] [Resolved] (KAFKA-17133) add unit test to make sure `ConsumerRecords#recoreds` returns immutable object

[ https://issues.apache.org/jira/browse/KAFKA-17133?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai resolved KAFKA-17133. Fix Version/s: 3.9.0 Resolution: Fixed > add unit test to make sure `ConsumerRecord

[jira] [Resolved] (KAFKA-17073) Deprecate ReplicaVerificationTool in 3.9

[ https://issues.apache.org/jira/browse/KAFKA-17073?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai resolved KAFKA-17073. Resolution: Fixed > Deprecate ReplicaVerificationTool in 3.9 > ---

Re: [PR] MINOR: update docs to 3.8 [kafka-site]

jlprat merged PR #608: URL: https://github.com/apache/kafka-site/pull/608 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: dev-unsubscr...@kafka.apache.o

[jira] [Resolved] (KAFKA-16743) Add support for share group heartbeat in KafkaApis

[ https://issues.apache.org/jira/browse/KAFKA-16743?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Apoorv Mittal resolved KAFKA-16743. --- Resolution: Fixed > Add support for share group heartbeat in KafkaApis > ---

[jira] [Resolved] (KAFKA-16744) Add support for share group describe in KafkaApis

[ https://issues.apache.org/jira/browse/KAFKA-16744?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Apoorv Mittal resolved KAFKA-16744. --- Resolution: Fixed > Add support for share group describe in KafkaApis >

[jira] [Resolved] (KAFKA-16750) Implement acknowledge API in SharePartitionManager

[ https://issues.apache.org/jira/browse/KAFKA-16750?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chirag Wadhwa resolved KAFKA-16750. --- Resolution: Fixed > Implement acknowledge API in SharePartitionManager > ---

[jira] [Created] (KAFKA-17142) Fix deadlock caused by LogManagerTest#testLogRecoveryMetrics

Chia-Ping Tsai created KAFKA-17142: -- Summary: Fix deadlock caused by LogManagerTest#testLogRecoveryMetrics Key: KAFKA-17142 URL: https://issues.apache.org/jira/browse/KAFKA-17142 Project: Kafka