Re: [ANNOUNCE] Apache Kafka 3.5.1
Thanks for running the release Divij. On Mon 24 Jul 2023 at 12:15, Kamal Chandraprakash < kamal.chandraprak...@gmail.com> wrote: > Thanks for running the release, Divij! > > On Mon, Jul 24, 2023 at 3:17 PM Divij Vaidya wrote: > > > The Apache Kafka community is pleased to announce the release for Apache > > Kafka 3.5.1 > > > > This release is a security patch release. It upgrades the dependency, > > snappy-java, to a version which is not vulnerable to CVE-2023-34455. You > > can find more information about the CVE at Kafka CVE list > > <https://kafka.apache.org/cve-list#CVE-2023-3445>. > > > > Additionally, this releases fixes a regression introduced in 3.3.0, which > > caused security.protocol configuration values to be restricted to upper > > case only. With this release, security.protocol values are > > case insensitive. See KAFKA-15053 > > <https://issues.apache.org/jira/browse/KAFKA-15053> for details. > > > > All of the changes in this release can be found in the release notes: > > https://www.apache.org/dist/kafka/3.5.1/RELEASE_NOTES.html > > > > You can download the source and binary release (Scala 2.11 and Scala > 2.12) > > from: > > https://kafka.apache.org/downloads#3.5.1 > > > > > > > --- > > > > Apache Kafka is a distributed streaming platform with four core APIs: > > > > > > ** The Producer API allows an application to publish a stream of records > to > > one or more Kafka topics. > > > > ** The Consumer API allows an application to subscribe to one or more > > topics and process the stream of records produced to them. > > > > ** The Streams API allows an application to act as a stream processor, > > consuming an input stream from one or more topics and producing an > > output stream to one or more output topics, effectively transforming the > > input streams to output streams. > > > > ** The Connector API allows building and running reusable producers or > > consumers that connect Kafka topics to existing applications or data > > systems. For example, a connector to a relational database might > > capture every change to a table. > > > > With these APIs, Kafka can be used for two broad classes of application: > > > > ** Building real-time streaming data pipelines that reliably get data > > between systems or applications. > > > > ** Building real-time streaming applications that transform or react > > to the streams of data. > > > > Apache Kafka is in use at large and small companies worldwide, including > > Capital One, Goldman Sachs, ING, LinkedIn, Netflix, Pinterest, Rabobank, > > 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, Chia-Ping Tsai, > > Chris Egerton, d00791190, Damon Xie, David Arthur, David Jacot, Divij > > Vaidya, DL1231, ezio, Manikumar Reddy, Manyanda Chitimbo, Mickael Maison, > > minjian.cai, Proven Provenzano, Sambhav Jain, vamossagar12, Yash Mayya > > > > We welcome your help and feedback. For more information on how to > > report problems, and to get involved, visit the project website at > > https://kafka.apache.org/ > > > > Thank you! > > > > Regards, > > Divij Vaidya > > Release Manager for Apache Kafka 3.5.1 > > > -- Manyanda Chitimbo.
Re: [DISCUSS] Apache Kafka 3.5.1 release
Thank you Divij for volunteering to perform the release. On Wed 28 Jun 2023 at 13:52, Divij Vaidya wrote: > Hey folks > > Looks like we are ready to perform a release for 3.5.1 to provide a fix for > the vulnerability in snappy-java [1] > > I would like to volunteer as release 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/apache/kafka/pull/12170
> update docs to include topoicId for kafka-topics.sh --describe output
> -
>
> Key: KAFKA-13875
> URL: https://issues.apache.org/jira/browse/KAFKA-13875
> Project: Kafka
> Issue Type: Improvement
> Components: admin
>Affects Versions: 3.2.0
>Reporter: Luke Chen
>Assignee: Richard Joerger
>Priority: Major
> Labels: newbie
>
> The topic describe output in quickstart doc here:
> [https://kafka.apache.org/quickstart] should be updated now.
> {code:java}
> bin/kafka-topics.sh --describe --topic quickstart-events --bootstrap-server
> localhost:9092
> Topic:quickstart-events PartitionCount:1ReplicationFactor:1 Configs:
> Topic: quickstart-events Partition: 0Leader: 0 Replicas: 0 Isr:
> 0{code}
> After Topic Id implementation, we included the topic id info in the output
> now. Also the configs is not empty now. The doc should be updated to avoid
> new users get confused.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
Re: [ANNOUNCE] Apache Kafka 3.5.0
Thank you for running the release! On Thu 15 Jun 2023 at 10:28, Mickael Maison wrote: > The Apache Kafka community is pleased to announce the release for Apache > Kafka 3.5.0. > > This is a minor release and it includes fixes and improvements from 201 > JIRAs. > > All of the changes in this release can be found in the release notes: > https://downloads.apache.org/kafka/3.5.0/RELEASE_NOTES.html > > An overview of the release can be found in our announcement blog post: > https://kafka.apache.org/blog > > You can download the source and binary release (Scala 2.12 and Scala 2.13) > from: > https://kafka.apache.org/downloads#3.5.0 > > > --- > > Apache Kafka is a distributed streaming platform with four core APIs: > ** The Producer API allows an application to publish a stream records to > one or more Kafka topics. > ** The Consumer API allows an application to subscribe to one or more > topics and process the stream of records produced to them. > ** The Streams API allows an application to act as a stream processor, > consuming an input stream from one or more topics and producing an output > stream to one or more output topics, effectively transforming the input > streams to output streams. > ** The Connector API allows building and running reusable producers or > consumers that connect Kafka topics to existing applications or data > systems. For example, a connector to a relational database might capture > every change to a table. > > With these APIs, Kafka can be used for two broad classes of application: > ** Building real-time streaming data pipelines that reliably get data > between systems or applications. > ** Building real-time streaming applications that transform or react to the > streams of data. > > Apache Kafka is in use at large and small companies worldwide, including > Capital One, Goldman Sachs, ING, LinkedIn, Netflix, Pinterest, Rabobank, > Target, The New York Times, Uber, Yelp, and Zalando, among others. > > A big thank you for the following 103 contributors to this release! > A. Sophie Blee-Goldman, Akhilesh Chaganti, Alex Sorokoumov, Alexandre > Dupriez, Alyssa Huang, Anastasia Vela, Andreas Maechler, andymg3, Artem > Livshits, atu-sharm, bachmanity1, Bill Bejeck, Brendan Ribera, Calvin Liu, > Chaitanya Mukka, Cheryl Simmons, Chia-Ping Tsai, Chris Egerton, Christo > Lolov, Colin P. McCabe, csolidum, Daniel Scanteianu, David Arthur, David > Jacot, David Karlsson, David Mao, Dejan Stojadinović, Divij Vaidya, dorwi, > drgnchan, Dániel Urbán, Edoardo Comar, egyedt, emilnkrastev, Eric Haag, > Farooq Qaiser, Federico Valeri, Gantigmaa Selenge, Greg Harris, Guozhang > Wang, Hao Li, Hector Geraldino, Himani Arora, Hoki Min, hudeqi, iamazy, > Iblis Lin, Ismael Juma, Ivan Yurchenko, 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, Luke Chen, Manikumar Reddy, Manyanda Chitimbo, > Matthew Wong, Matthias J. Sax, Matthias Seiler, Michael Marshall, Mickael > Maison, nicolasguyomar, Nikolay, Paolo Patierno, Philip Nee, Pierangelo Di > Pilato, Proven Provenzano, Purshotam Chauhan, Qing, Rajini Sivaram, > RivenSun, Robert Young, Rohan, Roman Schmitz, Ron Dagostino, Ruslan > Krivoshein, Satish Duggana, Shay Elkin, Shekhar Rajak, Simon Woodman, > Spacrocket, stejani-cflt, Terry, Tom Bentley, vamossagar12, Victoria Xia, > Viktor Somogyi-Vass, Vladimir Korenev, Yash Mayya, Zheng-Xian Li > > We welcome your help and feedback. For more information on how to report > problems, and to get involved, visit the project website at > https://kafka.apache.org/ > > Thank you! > > Regards, > Mickael Maison > -- Manyanda Chitimbo.
Re: [ANNOUNCE] New committer: Divij Vaidya
Congratulations Divij. On Tue 13 Jun 2023 at 17:50, Bruno Cadonna wrote: > Hi all, > > The PMC of Apache Kafka is pleased to announce a new Kafka committer > Divij Vaidya. > > Divij's major contributions are: > > GDPR compliance enforcement of kafka-site - > https://issues.apache.org/jira/browse/KAFKA-13868 > > Performance improvements: > > Improve performance of VarInt encoding and decoding - > https://github.com/apache/kafka/pull/13312 > > Reduce data copy & buffer allocation during decompression - > https://github.com/apache/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-14985
Project: Kafka
Issue Type: Test
Reporter: Manyanda Chitimbo
The test sometimes fails with the following error
{code:java}
Gradle Test Run :core:test > Gradle Test Executor 14 > ConnectionQuotasTest >
testListenerConnectionRateLimitWhenActualRateAboveLimit() FAILED
java.util.concurrent.ExecutionException:
org.opentest4j.AssertionFailedError: Expected rate (30 +- 7), but got
37.47891810856393 (600 connections / 16.009 sec) ==> expected: <30.0> but was:
<37.47891810856393>
at java.base/java.util.concurrent.FutureTask.report(FutureTask.java:122)
at java.base/java.util.concurrent.FutureTask.get(FutureTask.java:205)
at
kafka.network.ConnectionQuotasTest.$anonfun$testListenerConnectionRateLimitWhenActualRateAboveLimit$3(ConnectionQuotasTest.scala:412)
at scala.collection.immutable.List.foreach(List.scala:333)
at
kafka.network.ConnectionQuotasTest.testListenerConnectionRateLimitWhenActualRateAboveLimit(ConnectionQuotasTest.scala:412)
Caused by:
org.opentest4j.AssertionFailedError: Expected rate (30 +- 7), but got
37.47891810856393 (600 connections / 16.009 sec) ==> expected: <30.0> but was:
<37.47891810856393>
at
app//org.junit.jupiter.api.AssertionFailureBuilder.build(AssertionFailureBuilder.java:151)
at
app//org.junit.jupiter.api.AssertionFailureBuilder.buildAndThrow(AssertionFailureBuilder.java:132)
at
app//org.junit.jupiter.api.AssertEquals.failNotEqual(AssertEquals.java:197)
at
app//org.junit.jupiter.api.AssertEquals.assertEquals(AssertEquals.java:86)
at
app//org.junit.jupiter.api.Assertions.assertEquals(Assertions.java:1021)
at
app//kafka.network.ConnectionQuotasTest.acceptConnectionsAndVerifyRate(ConnectionQuotasTest.scala:904)
{code}
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
[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
Project: Kafka
Issue Type: Test
Reporter: Manyanda Chitimbo
The test sometimes fails with the below log
{code:java}
kafka.server.DynamicBrokerReconfigurationTest.testThreadPoolResize() failed,
log available in
.../core/build/reports/testOutput/kafka.server.DynamicBrokerReconfigurationTest.testThreadPoolResize().test.stdoutGradle
Test Run :core:test > Gradle Test Executor 6 >
DynamicBrokerReconfigurationTest > testThreadPoolResize() FAILED
org.opentest4j.AssertionFailedError: Invalid threads: expected 6, got 8:
List(data-plane-kafka-socket-acceptor-ListenerName(PLAINTEXT)-PLAINTEXT-0,
data-plane-kafka-socket-acceptor-ListenerName(PLAINTEXT)-PLAINTEXT-0,
data-plane-kafka-socket-acceptor-ListenerName(INTERNAL)-SSL-0,
data-plane-kafka-socket-acceptor-ListenerName(EXTERNAL)-SASL_SSL-0,
data-plane-kafka-socket-acceptor-ListenerName(INTERNAL)-SSL-0,
data-plane-kafka-socket-acceptor-ListenerName(INTERNAL)-SSL-0,
data-plane-kafka-socket-acceptor-ListenerName(EXTERNAL)-SASL_SSL-0,
data-plane-kafka-socket-acceptor-ListenerName(EXTERNAL)-SASL_SSL-0) ==>
expected: but was:
at
app//org.junit.jupiter.api.AssertionFailureBuilder.build(AssertionFailureBuilder.java:151)
at
app//org.junit.jupiter.api.AssertionFailureBuilder.buildAndThrow(AssertionFailureBuilder.java:132)
at app//org.junit.jupiter.api.AssertTrue.failNotTrue(AssertTrue.java:63)
at app//org.junit.jupiter.api.AssertTrue.assertTrue(AssertTrue.java:36)
at app//org.junit.jupiter.api.Assertions.assertTrue(Assertions.java:211)
at
app//kafka.server.DynamicBrokerReconfigurationTest.verifyThreads(DynamicBrokerReconfigurationTest.scala:1634)
at
app//kafka.server.DynamicBrokerReconfigurationTest.testThreadPoolResize(DynamicBrokerReconfigurationTest.scala:872)
{code}
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
[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: Kafka
Issue Type: Test
Reporter: Manyanda Chitimbo
Assignee: Manyanda Chitimbo
When running the test suite locally I noticed the following error
{code:java}
org.opentest4j.AssertionFailedError: expected: but was:
at
app//org.junit.jupiter.api.AssertionFailureBuilder.build(AssertionFailureBuilder.java:151)
at
app//org.junit.jupiter.api.AssertionFailureBuilder.buildAndThrow(AssertionFailureBuilder.java:132)
at app//org.junit.jupiter.api.AssertTrue.failNotTrue(AssertTrue.java:63)
at app//org.junit.jupiter.api.AssertTrue.assertTrue(AssertTrue.java:36)
at app//org.junit.jupiter.api.AssertTrue.assertTrue(AssertTrue.java:31)
at app//org.junit.jupiter.api.Assertions.assertTrue(Assertions.java:180)
at
app//org.apache.kafka.clients.consumer.internals.DefaultBackgroundThreadTest.testStartupAndTearDown(DefaultBackgroundThreadTest.java:95)
{code}
which happened only once and I could reproduce it again.
I further noticed some NPE in debug logs in the form of
{code:java}
ERROR The background thread failed due to unexpected error
(org.apache.kafka.clients.consumer.internals.DefaultBackgroundThread:166)
java.lang.NullPointerException
at
org.apache.kafka.clients.consumer.internals.DefaultBackgroundThread.handlePollResult(DefaultBackgroundThread.java:200)
at
java.base/java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:195)
at
java.base/java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:195)
at
java.base/java.util.stream.ReferencePipeline$2$1.accept(ReferencePipeline.java:177)
at
java.base/java.util.HashMap$ValueSpliterator.forEachRemaining(HashMap.java:1675)
at
java.base/java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:484)
at
java.base/java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:474)
at
java.base/java.util.stream.ReduceOps$ReduceOp.evaluateSequential(ReduceOps.java:913)
at
java.base/java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:234)
at
java.base/java.util.stream.ReferencePipeline.reduce(ReferencePipeline.java:553)
at
org.apache.kafka.clients.consumer.internals.DefaultBackgroundThread.runOnce(DefaultBackgroundThread.java:187)
at
org.apache.kafka.clients.consumer.internals.DefaultBackgroundThread.run(DefaultBackgroundThread.java:159)
{code}
which is due to missing stubs.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
[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 Issue Type: Improvement Components: core Reporter: Manyanda Chitimbo Assignee: Divij Vaidya Fix For: 3.6.0 We register metrics with the KafkaMetricsGroup in LogCleaner.scala but we don't remove them on shutdown. -- This message was sent by Atlassian Jira (v8.20.10#820010)
Re: Test failures
irror.integration.MirrorConnectorsIntegrationExactlyOnceTest.testNoCheckpointsIfNoRecordsAreMirrored() > > > > > > > > Build / JDK 11 and Scala 2.12 / > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > org.apache.kafka.connect.mirror.integration.MirrorConnectorsIntegrationExactlyOnceTest.testOneWayReplicationWithAutoOffsetSync() > > > > > > > > Build / JDK 11 and Scala 2.12 / > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > org.apache.kafka.connect.mirror.integration.MirrorConnectorsIntegrationExactlyOnceTest.testSyncTopicConfigs() > > > > > > > > Build / JDK 11 and Scala 2.12 / > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > org.apache.kafka.connect.mirror.integration.MirrorConnectorsIntegrationExactlyOnceTest.testRestartReplication() > > > > > > > > Build / JDK 11 and Scala 2.12 / > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > org.apache.kafka.connect.mirror.integration.MirrorConnectorsIntegrationExactlyOnceTest.testOneWayReplicationWithFrequentOffsetSyncs() > > > > > > > > Build / JDK 11 and Scala 2.12 / > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > org.apache.kafka.connect.mirror.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
Congratulations Mickael. And thanks Jun for the work over the years. On Fri, Apr 21, 2023 at 5:10 PM Jun Rao wrote: > Hi, everyone, > > After more than 10 years, I am stepping down as the PMC chair of Apache > Kafka. We now have a new chair Mickael Maison, who has been a PMC member > since 2020. I plan to continue to contribute to Apache Kafka myself. > > Congratulations, Mickael! > > Jun > -- Manyanda Chitimbo.
