Re: [ANNOUNCE] Apache Kafka 3.5.1

k, > > Target, The New York Times, Uber, Yelp, and Zalando, among others. > > > > A big thank you for the following 22 contributors to this release! > (Please > > report an unintended omission) > > > > Alyssa Huang, Aman Singh, andymg3, Bo Gao, Calvin Liu, C

Re: [DISCUSS] Apache Kafka 3.5.1 release

se manager for the 3.5.1 release. > > If there are no objections, I will start a release plan next Monday, on 3rd > July. > > [1] https://nvd.nist.gov/vuln/detail/CVE-2023-34455 > > -- > Divij Vaidya > -- Manyanda Chitimbo.

[jira] [Resolved] (KAFKA-13875) update docs to include topoicId for kafka-topics.sh --describe output

[ https://issues.apache.org/jira/browse/KAFKA-13875?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manyanda Chitimbo resolved KAFKA-13875. --- Resolution: Fixed Closing the Jira as it has been fixed by https://github.com

Re: [ANNOUNCE] Apache Kafka 3.5.0

enko, Jakub Scholz, Jason Gustafson, Jeff > Kim, Jim Galasyn, Jorge Esteban Quilcate Otoya, Josep Prat, José Armando > García Sancio, Juan José Ramos, Junyang Liu, Justine Olshan, Kamal > Chandraprakash, Kirk True, Kowshik Prakasam, littlehorse-eng, liuzc9, Lucas > Brutschy, Lucia Cerchie

Re: [ANNOUNCE] New committer: Divij Vaidya

che/kafka/pull/13135 > > He also was heavily involved in the migration to Mockito. > > Furthermore, Divij is very active on the mailing lists as well as in > maintaining and reviewing pull requests. > > Congratulations, Divij! > > Thanks, > > Bruno (on behalf of the Apache Kafka PMC) > > > -- Manyanda Chitimbo.

[jira] [Created] (KAFKA-14985) ConnectionQuotasTest.testListenerConnectionRateLimitWhenActualRateAboveLimit() test is flaky

Manyanda Chitimbo created KAFKA-14985: - Summary: ConnectionQuotasTest.testListenerConnectionRateLimitWhenActualRateAboveLimit() test is flaky Key: KAFKA-14985 URL: https://issues.apache.org/jira/browse/KAFKA

[jira] [Created] (KAFKA-14984) DynamicBrokerReconfigurationTest.testThreadPoolResize() test is flaky

Manyanda Chitimbo created KAFKA-14984: - Summary: DynamicBrokerReconfigurationTest.testThreadPoolResize() test is flaky Key: KAFKA-14984 URL: https://issues.apache.org/jira/browse/KAFKA-14984

[jira] [Created] (KAFKA-14961) DefaultBackgroundThreadTest.testStartupAndTearDown test is flasky

Manyanda Chitimbo created KAFKA-14961: - Summary: DefaultBackgroundThreadTest.testStartupAndTearDown test is flasky Key: KAFKA-14961 URL: https://issues.apache.org/jira/browse/KAFKA-14961 Project

[jira] [Created] (KAFKA-14959) Remove metrics on ClientQuota Managers shutdown

Manyanda Chitimbo created KAFKA-14959: - Summary: Remove metrics on ClientQuota Managers shutdown Key: KAFKA-14959 URL: https://issues.apache.org/jira/browse/KAFKA-14959 Project: Kafka

Re: Test failures

ror.integration.MirrorConnectorsIntegrationSSLTest.testReplication() > > > > > > > > Build / JDK 11 and Scala 2.12 / > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > org.apache.kafka.connect.mirror.integration.MirrorConnectorsIntegrationSSLTest.testReplicationWithEmptyPartition() > > > > > > > > Build / JDK 11 and Scala 2.12 / > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > org.apache.kafka.connect.mirror.integration.MirrorConnectorsIntegrationSSLTest.testReplicateSourceDefault() > > > > > > > > Build / JDK 11 and Scala 2.12 / > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > org.apache.kafka.connect.mirror.integration.MirrorConnectorsIntegrationSSLTest.testOffsetSyncsTopicsOnTarget() > > > > > > > > Build / JDK 11 and Scala 2.12 / > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > org.apache.kafka.connect.mirror.integration.MirrorConnectorsIntegrationSSLTest.testReplicateTargetDefault() > > > > > > > > Build / JDK 11 and Scala 2.12 / > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > org.apache.kafka.connect.mirror.integration.MirrorConnectorsIntegrationSSLTest.testNoCheckpointsIfNoRecordsAreMirrored() > > > > > > > > Build / JDK 11 and Scala 2.12 / > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > org.apache.kafka.connect.integration.ConnectorClientPolicyIntegrationTest.testCreateWithAllowedOverridesForPrincipalPolicy > > > > > > > > Build / JDK 11 and Scala 2.12 / > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > org.apache.kafka.connect.integration.ConnectorClientPolicyIntegrationTest.testCreateWithOverridesForNonePolicy > > > > > > > > Build / JDK 11 and Scala 2.12 / > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > org.apache.kafka.connect.integration.ConnectorClientPolicyIntegrationTest.testCreateWithAllowedOverridesForDefaultPolicy > > > > > > > > Build / JDK 11 and Scala 2.12 / > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > org.apache.kafka.connect.integration.ConnectorClientPolicyIntegrationTest.testCreateWithNoAllowedOverridesForNonePolicy > > > > > > > > Build / JDK 11 and Scala 2.12 / > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > org.apache.kafka.connect.integration.ConnectorTopicsIntegrationTest.testGetActiveTopics > > > > > > > > Build / JDK 11 and Scala 2.12 / > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > org.apache.kafka.connect.integration.ConnectorTopicsIntegrationTest.testTopicTrackingResetIsDisabled > > > > > > > > Build / JDK 11 and Scala 2.12 / > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > org.apache.kafka.connect.integration.ConnectorTopicsIntegrationTest.testTopicTrackingIsDisabled > > > > > > > > Build / JDK 11 and Scala 2.12 / > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > org.apache.kafka.connect.integration.ExactlyOnceSourceIntegrationTest.testSeparateOffsetsTopic > > > > > > > > Build / JDK 11 and Scala 2.12 / > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > org.apache.kafka.connect.integration.ExampleConnectIntegrationTest.testSinkConnector > > > > > > > > Build / JDK 11 and Scala 2.12 / > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > org.apache.kafka.connect.integration.OffsetsApiIntegrationTest.testGetSinkConnectorOffsets > > > > > > > > Build / JDK 11 and Scala 2.12 / > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > org.apache.kafka.connect.integration.OffsetsApiIntegrationTest.testGetNonExistentConnectorOffsets > > > > > > > > Build / JDK 11 and Scala 2.12 / > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > org.apache.kafka.connect.integration.OffsetsApiIntegrationTest.testGetSinkConnectorOffsetsOverriddenConsumerGroupId > > > > > > > > Build / JDK 11 and Scala 2.12 / > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > org.apache.kafka.connect.integration.OffsetsApiIntegrationTest.testGetSourceConnectorOffsets > > > > > > > > Build / JDK 11 and Scala 2.12 / > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > org.apache.kafka.connect.integration.OffsetsApiIntegrationTest.testGetSinkConnectorOffsetsDifferentKafkaClusterTargeted > > > > > > > > Build / JDK 11 and Scala 2.12 / > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > integration.kafka.server.FetchFromFollowerIntegrationTest.testRackAwareRangeAssignor() > > > > > > > > Build / JDK 11 and Scala 2.12 / > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > kafka.security.authorizer.AuthorizerTest.testSuperUserHasAccess(String).quorum=kraft > > > > > > > > Build / JDK 11 and Scala 2.12 / > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > kafka.security.authorizer.AuthorizerTest.testSingleCharacterResourceAcls(String).quorum=kraft > > > > > > > > Build / JDK 11 and Scala 2.12 / > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > kafka.security.authorizer.AuthorizerTest.testSingleCharacterResourceAcls(String).quorum=kraft > > > > > > > > Build / JDK 11 and Scala 2.12 / > > > > > > > > kafka.network.SocketServerTest.testConnectionRateLimit() > > > > > > > > Build / JDK 11 and Scala 2.12 / > > > > > > > > kafka.server.RaftClusterSnapshotTest.testSnapshotsGenerated() > > > > > > > > Build / JDK 11 and Scala 2.12 / > > > > > kafka.zk.ZkMigrationIntegrationTest.[1] > > > > > > > > Type=ZK, Name=testDualWrite, MetadataVersion=3.4-IV0, > > > > > > Security=PLAINTEXT > > > > > > > > Build / JDK 11 and Scala 2.12 / > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > org.apache.kafka.controller.QuorumControllerTest.testDelayedConfigurationOperations() > > > > > > > > Build / JDK 17 and Scala 2.13 / > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > org.apache.kafka.connect.mirror.integration.MirrorConnectorsWithCustomForwardingAdminIntegrationTest.testReplicationIsCreatingTopicsUsingProvidedForwardingAdmin() > > > > > > > > Build / JDK 17 and Scala 2.13 / > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > org.apache.kafka.connect.mirror.integration.MirrorConnectorsWithCustomForwardingAdminIntegrationTest.testCreatePartitionsUseProvidedForwardingAdmin() > > > > > > > > Build / JDK 17 and Scala 2.13 / > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > org.apache.kafka.connect.mirror.integration.MirrorConnectorsWithCustomForwardingAdminIntegrationTest.testSyncTopicConfigUseProvidedForwardingAdmin() > > > > > > > > Build / JDK 17 and Scala 2.13 / > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > org.apache.kafka.connect.mirror.integration.MirrorConnectorsWithCustomForwardingAdminIntegrationTest.testReplicationIsCreatingTopicsUsingProvidedForwardingAdmin() > > > > > > > > Build / JDK 17 and Scala 2.13 / > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > org.apache.kafka.connect.mirror.integration.MirrorConnectorsWithCustomForwardingAdminIntegrationTest.testCreatePartitionsUseProvidedForwardingAdmin() > > > > > > > > Build / JDK 17 and Scala 2.13 / > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > org.apache.kafka.connect.mirror.integration.MirrorConnectorsWithCustomForwardingAdminIntegrationTest.testSyncTopicConfigUseProvidedForwardingAdmin() > > > > > > > > Build / JDK 8 and Scala 2.12 / > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > org.apache.kafka.connect.mirror.integration.MirrorConnectorsWithCustomForwardingAdminIntegrationTest.testReplicationIsCreatingTopicsUsingProvidedForwardingAdmin() > > > > > > > > Build / JDK 8 and Scala 2.12 / > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > org.apache.kafka.connect.mirror.integration.MirrorConnectorsWithCustomForwardingAdminIntegrationTest.testCreatePartitionsUseProvidedForwardingAdmin() > > > > > > > > Build / JDK 8 and Scala 2.12 / > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > org.apache.kafka.connect.mirror.integration.MirrorConnectorsWithCustomForwardingAdminIntegrationTest.testSyncTopicConfigUseProvidedForwardingAdmin() > > > > > > > > Build / JDK 8 and Scala 2.12 / > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > org.apache.kafka.connect.mirror.integration.MirrorConnectorsWithCustomForwardingAdminIntegrationTest.testReplicationIsCreatingTopicsUsingProvidedForwardingAdmin() > > > > > > > > Build / JDK 8 and Scala 2.12 / > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > org.apache.kafka.connect.mirror.integration.MirrorConnectorsWithCustomForwardingAdminIntegrationTest.testCreatePartitionsUseProvidedForwardingAdmin() > > > > > > > > Build / JDK 8 and Scala 2.12 / > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > org.apache.kafka.connect.mirror.integration.MirrorConnectorsWithCustomForwardingAdminIntegrationTest.testSyncTopicConfigUseProvidedForwardingAdmin() > > > > > > > > Build / JDK 11 and Scala 2.13 / > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > org.apache.kafka.connect.mirror.integration.MirrorConnectorsWithCustomForwardingAdminIntegrationTest.testReplicationIsCreatingTopicsUsingProvidedForwardingAdmin() > > > > > > > > Build / JDK 11 and Scala 2.13 / > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > org.apache.kafka.connect.mirror.integration.MirrorConnectorsWithCustomForwardingAdminIntegrationTest.testCreatePartitionsUseProvidedForwardingAdmin() > > > > > > > > Build / JDK 11 and Scala 2.13 / > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > org.apache.kafka.connect.mirror.integration.MirrorConnectorsWithCustomForwardingAdminIntegrationTest.testSyncTopicConfigUseProvidedForwardingAdmin() > > > > > > > > Build / JDK 11 and Scala 2.12 / > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > org.apache.kafka.connect.mirror.integration.MirrorConnectorsWithCustomForwardingAdminIntegrationTest.testReplicationIsCreatingTopicsUsingProvidedForwardingAdmin() > > > > > > > > Build / JDK 11 and Scala 2.12 / > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > org.apache.kafka.connect.mirror.integration.MirrorConnectorsWithCustomForwardingAdminIntegrationTest.testCreatePartitionsUseProvidedForwardingAdmin() > > > > > > > > Build / JDK 11 and Scala 2.12 / > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > org.apache.kafka.connect.mirror.integration.MirrorConnectorsWithCustomForwardingAdminIntegrationTest.testSyncTopicConfigUseProvidedForwardingAdmin() > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > https://ci-builds.apache.org/job/Kafka/job/kafka/job/trunk/1764/#showFailuresLink > > > > > > > > > > > > > > > > Ismael > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > -- Manyanda Chitimbo.

Re: [ANNOUNCE] New PMC chair: Mickael Maison

> since 2020. I plan to continue to contribute to Apache Kafka myself. > > Congratulations, Mickael! > > Jun > -- Manyanda Chitimbo.