This is an automated email from the ASF dual-hosted git repository.
engelen pushed a change to branch update/kafka-clients-4.0.0
in repository https://gitbox.apache.org/repos/asf/pekko-connectors-kafka.git
omit b1f58007 Update link-validator.conf
omit 6ca1ef5a java 11 build
omit 0fca3707 deprecation issues
omit 5842b517 Create kafka-clients-4.0-upgrade.excludes
omit 56ca1631 test compile issues
omit c6d7ec3b Update KafkaSpec.scala
omit a281570c Update ConsumerResetProtection.scala
omit fab3db74 Update KafkaConsumerActor.scala
omit 04472902 try to fix compile issues
omit d94d8d36 Update kafka-clients to 4.0.0
add 386d14e2 Update sbt, scripted-plugin to 1.10.11 (#297)
add 8a9fae12 remove caveat about bin compatibility (#298)
add 5d1e0836 doc: update kafka-client recommendation (#284)
add 3dda6f4f test with latest available confluent images (#299)
add 6ee76840 add testcontainers ref to license (#302)
add c6a01ccc Update junit-jupiter-api to 5.12.2 (#307)
add 7671a8d0 pin sbt-java-formatter to 0.9.x (#308)
add 8c4eb816 Update sbt-java-formatter to 0.9.0 (#309)
add 5c4e7d2b remove old ref for no longer existing config (#305)
add 2957a88a test with confluent 7.9.0 docker images (#303)
add 0ff8c646 Update kafka to 1.21.0 (#311)
add ce9578ef Update protobuf-java to 3.25.7 (#310)
add f5f2c325 Update kafka-avro-serializer to 7.9.1 (#312)
add 26887891 Update scala3-library to 3.3.6 (#313)
add 26f261c7 Update metrics-core to 4.2.32 (#314)
add bce988d8 Update sbt, scripted-plugin to 1.11.0 (#316)
add a26e13ce Update kafka-clients to 3.9.1 (#315)
add 9e9bb1d3 Update kafka to 1.21.1 (#320)
add 13d5918e Update protobuf-java to 3.25.8 (#318)
add 6e28ecdf Update junit-jupiter-api to 5.13.0 (#319)
add 45990fbc Update scalapb-runtime to 0.11.18 (#323)
add 6b72eff3 Update sbt, scripted-plugin to 1.11.2 (#325)
add f27d9792 Update junit-jupiter-api to 5.13.1 (#324)
add b8a53921 Update kafka-avro-serializer to 7.9.2 (#326)
add 363096fb Pin GitHub Actions (#327)
add 7b63fe7d Update kafka to 1.21.2 (#330)
add caf3665f Update metrics-core to 4.2.33 (#329)
add 3a62e038 pekko 1.1.4 (#331)
add 2bfef29f upgrade jupiter-interface (#334)
add 26d73170 remove int-test usage (#333)
add 32f0ad8d Update kafka to 1.21.3 (#340)
add fe5918c4 Update junit-jupiter-api to 5.13.2 (#338)
add 5f01091b Update sbt-dynver to 5.1.1 (#336)
add 72dfa7d5 Update sbt-pekko-build to 0.4.4 (#335)
add 92c04ac8 Update scalapb-runtime to 0.11.19 (#337)
add f04a392b Update junit-jupiter-api to 5.13.3 (#341)
add add1c688 Update sbt, scripted-plugin to 1.11.3 (#342)
add 4e181bb0 Update sbt-scalafmt to 2.5.5 (#343)
add bc253867 Update sbt-pekko-build to 0.4.5 (#344)
add 51b43681 pekko 1.1.5 (#345)
add 08762349 Update commons-codec to 1.19.0 (#346)
add d47e0389 Update junit-jupiter-api to 5.13.4 (#347)
add 447a25cc Update jupiter-interface, ... to 0.15.1 (#348)
add 0721402d Update sbt, scripted-plugin to 1.11.4 (#349)
add 0c195ed0 Update scalapb-runtime to 0.11.20 (#352)
add 96884d35 Update sbt-unidoc to 0.6.0 (#351)
add 3fcf6dbc Update sbt, scripted-plugin to 1.11.5 (#354)
add 1a0388a3 support allowing to test with confluent v7 and v8 docker
images (#332)
add 3e629bb3 protect 1.1.x branch (#350)
add de1e76e7 Update sbt, scripted-plugin to 1.11.6 (#357)
add 04391eb1 Update sbt-header to 5.11.0
add 2244132c fix imports
add 6f20daf5 Update sbt-license-report to 1.8.0
add 5965a14e protect 1.2.x branch (#365)
add 541d44c9 drop Scala 2.12 support (#366)
add 416d354f use scala converters (#367)
add 10282b58 build with java 17 (#364)
add fc625a47 Remove some deprecated code (#369)
add ea41fdd5 Clean up dependency version pinning in config (#370)
add 05620a91 Update mockito-core to 5.20.0 (#375)
add 019094be Update jackson-databind to 2.20.0 (#373)
add c4033c20 Update logback-classic to 1.5.18 (#372)
add bde70d8a Update protobuf-java to 4.32.1 (#374)
add 67a5cffb Kafka Client 4.1.0 (#358)
add b92d0593 Update sbt-license-report to 1.9.0 (#376)
add 54de2700 Update kafka-avro-serializer to 8.0.1 (#377)
add f54a36e2 Update junit jupiter to 6.0.0 (#380)
add 14a03e68 Update logback-classic to 1.5.19 (#378)
add 677b0058 Update sbt, scripted-plugin to 1.11.7
add e939ccf7 Update scala-library to 2.13.17
add d9a65e9c Update kafka-avro-serializer to 8.0.2
add 414ece4a Update jupiter-interface, ... to 0.15.2
add 4e7ef868 Update jupiter-interface, ... to 0.17.0
add a3cf6392 Update sbt-source-dist to 0.1.13 (#381)
add 081990e4 Update scala3-library to 3.3.7
add ddfe6e31 Update kafka-avro-serializer to 8.1.0 (#388)
add f691296c Update protobuf-java to 4.33.0 (#387)
add 1c8927ff java 17 build
add 74bc4bb5 Update link-validator.conf
This update added new revisions after undoing existing revisions.
That is to say, some revisions that were in the old version of the
branch are not in the new version. This situation occurs
when a user --force pushes a change and generates a repository
containing something like this:
* -- * -- B -- O -- O -- O (b1f58007)
\
N -- N -- N refs/heads/update/kafka-clients-4.0.0 (74bc4bb5)
You should already have received notification emails for all of the O
revisions, and so the following emails describe only the N revisions
from the common base, B.
Any revisions marked "omit" are not gone; other references still
refer to them. Any revisions marked "discard" are gone forever.
No new revisions were added by this update.
Summary of changes:
.asf.yaml | 24 +++
.github/workflows/check-build-test.yml | 83 +++++-----
.github/workflows/format.yml | 2 +-
.github/workflows/headers.yml | 12 +-
.github/workflows/link-validator.yml | 14 +-
.github/workflows/nightly-pekko.yml | 38 ++---
.github/workflows/publish-1.0-docs.yml | 8 +-
.github/workflows/publish-1.1-docs.yml | 8 +-
.github/workflows/publish-nightly.yml | 12 +-
.github/workflows/scala-steward.yml | 2 +-
.scala-steward.conf | 11 --
LICENSE | 29 ++++
README.md | 4 -
.../pekko/kafka/benchmarks/InflightMetrics.scala | 2 +-
.../kafka/benchmarks/KafkaConsumerBenchmarks.scala | 2 +-
.../kafka/benchmarks/KafkaConsumerFixtureGen.scala | 3 +-
.../benchmarks/KafkaTransactionBenchmarks.scala | 2 +-
.../benchmarks/KafkaTransactionFixtureGen.scala | 3 +-
.../ReactiveKafkaConsumerBenchmarks.scala | 3 +-
.../pekko/kafka/benchmarks/BatchedConsumer.scala | 0
.../apache/pekko/kafka/benchmarks/Benchmarks.scala | 0
.../kafka/benchmarks/NoCommitBackpressure.scala | 0
.../PekkoConnectorsCommittableProducer.scala | 0
.../apache/pekko/kafka/benchmarks/Producer.scala | 0
.../apache/pekko/kafka/benchmarks/SpecBase.scala | 0
.../pekko/kafka/benchmarks/Transactions.scala | 0
build.sbt | 40 ++---
.../cluster/sharding/KafkaClusterSharding.scala | 10 +-
.../remove-deprecated-code.excludes | 41 +++++
core/src/main/resources/reference.conf | 2 +-
.../org/apache/pekko/kafka/CommitterSettings.scala | 5 +-
.../pekko/kafka/ConnectionCheckerSettings.scala | 10 +-
.../org/apache/pekko/kafka/ConsumerMessage.scala | 11 +-
.../org/apache/pekko/kafka/ConsumerSettings.scala | 66 ++++----
.../scala/org/apache/pekko/kafka/Metadata.scala | 27 +---
.../kafka/OffsetResetProtectionSettings.scala | 9 +-
.../org/apache/pekko/kafka/ProducerMessage.scala | 2 +-
.../org/apache/pekko/kafka/ProducerSettings.scala | 22 +--
.../org/apache/pekko/kafka/Subscriptions.scala | 10 +-
.../pekko/kafka/internal/CommittableSources.scala | 5 +-
.../pekko/kafka/internal/ConfigSettings.scala | 8 +-
.../kafka/internal/ConsumerProgressTracking.scala | 2 +-
.../kafka/internal/ConsumerResetProtection.scala | 2 +-
.../kafka/internal/ControlImplementations.scala | 9 +-
.../pekko/kafka/internal/DeferredProducer.scala | 7 +-
.../pekko/kafka/internal/KafkaConsumerActor.scala | 30 ++--
.../pekko/kafka/internal/MessageBuilder.scala | 11 +-
.../internal/PartitionAssignmentHelpers.scala | 2 +-
.../pekko/kafka/internal/SubSourceLogic.scala | 1 -
.../internal/TransactionalProducerStage.scala | 2 +-
.../kafka/internal/TransactionalSources.scala | 1 -
.../org/apache/pekko/kafka/javadsl/Committer.scala | 2 +-
.../org/apache/pekko/kafka/javadsl/Consumer.scala | 14 +-
.../pekko/kafka/javadsl/DiscoverySupport.scala | 4 +-
.../pekko/kafka/javadsl/MetadataClient.scala | 30 ++--
.../org/apache/pekko/kafka/javadsl/Producer.scala | 172 +--------------------
.../apache/pekko/kafka/javadsl/SendProducer.scala | 8 +-
.../apache/pekko/kafka/javadsl/Transactional.scala | 3 +-
.../apache/pekko/kafka/scaladsl/Committer.scala | 5 +-
.../org/apache/pekko/kafka/scaladsl/Consumer.scala | 11 +-
.../pekko/kafka/scaladsl/DiscoverySupport.scala | 4 +-
.../pekko/kafka/scaladsl/MetadataClient.scala | 21 +--
.../org/apache/pekko/kafka/scaladsl/Producer.scala | 158 -------------------
.../apache/pekko/kafka/scaladsl/SendProducer.scala | 9 +-
docs/src/main/paradox/home.md | 4 +-
docs/src/main/paradox/serialization.md | 10 +-
.../src/test}/resources/logback-test.xml | 0
.../src/test}/resources/reference.conf | 0
.../org/apache/pekko/kafka/IntegrationTests.scala | 3 +-
.../kafka/PartitionedSourceFailoverSpec.scala | 0
.../pekko/kafka/PlainSourceFailoverSpec.scala | 0
.../kafka/TransactionsPartitionedSourceSpec.scala | 0
.../pekko/kafka/TransactionsSourceSpec.scala | 0
.../src/test/java/docs/javadsl/ProducerTest.java | 8 +-
.../test/java/docs/javadsl/TestkitSamplesTest.java | 9 +-
.../java/docs/javadsl/proto/OrderMessages.java | 33 ++--
project/CopyrightHeader.scala | 6 +-
project/CopyrightHeaderForBuild.scala | 2 +-
project/CopyrightHeaderForProtobuf.scala | 2 +-
project/Dependencies.scala | 14 +-
project/PekkoCoreDependency.scala | 2 +-
project/ProjectSettings.scala | 10 +-
project/Versions.scala | 15 +-
project/build.properties | 2 +-
project/plugins.sbt | 23 +--
project/project-info.conf | 2 +-
scripts/link-validator.conf | 1 +
.../org/apache/pekko/kafka/testkit/KafkaTest.java | 11 --
.../testkit/TestcontainersKafkaJunit4Test.java | 11 --
.../kafka/testkit/TestcontainersKafkaTest.java | 10 --
.../testkit/internal/KafkaContainerCluster.java | 103 +++++++-----
.../internal/PekkoConnectorsKafkaContainer.java | 3 +-
.../pekko/kafka/testkit/javadsl/BaseKafkaTest.java | 14 +-
.../kafka/testkit/javadsl/KafkaJunit4Test.java | 11 --
.../docker-confluent-8.0-upgrade.excludes | 4 +-
testkit/src/main/resources/reference.conf | 3 +-
.../KafkaTestkitTestcontainersSettings.scala | 17 +-
.../kafka/testkit/ProducerResultFactory.scala | 2 +-
.../kafka/testkit/internal/KafkaTestKit.scala | 3 +-
.../testkit/internal/TestcontainersKafka.scala | 23 +--
.../pekko/kafka/testkit/scaladsl/KafkaSpec.scala | 2 +-
.../testkit/scaladsl/TestcontainersKafkaLike.scala | 2 +-
.../scaladsl/SchemaRegistrySerializationSpec.scala | 8 +-
.../scala/docs/scaladsl/proto/OrderProto.scala | 2 -
.../org/apache/pekko/kafka/TransactionsOps.scala | 1 -
.../internal/CommittingProducerSinkSpec.scala | 2 +-
.../pekko/kafka/internal/ConsumerDummy.scala | 1 +
.../apache/pekko/kafka/internal/ConsumerMock.scala | 8 +-
.../internal/ConsumerProgressTrackingSpec.scala | 2 +-
.../internal/ConsumerResetProtectionSpec.scala | 2 +-
.../apache/pekko/kafka/internal/ConsumerSpec.scala | 2 +-
.../kafka/internal/PartitionedSourceSpec.scala | 2 +-
.../apache/pekko/kafka/internal/ProducerSpec.scala | 2 +-
.../apache/pekko/kafka/javadsl/ControlSpec.scala | 2 +-
.../pekko/kafka/scaladsl/RebalanceSpec.scala | 2 +-
.../pekko/kafka/scaladsl/RetentionPeriodSpec.scala | 10 +-
.../pekko/kafka/scaladsl/TimestampSpec.scala | 2 +-
.../pekko/kafka/tests/CapturingAppender.scala | 2 +-
118 files changed, 547 insertions(+), 906 deletions(-)
rename benchmarks/src/{it =>
test}/scala/org/apache/pekko/kafka/benchmarks/BatchedConsumer.scala (100%)
rename benchmarks/src/{it =>
test}/scala/org/apache/pekko/kafka/benchmarks/Benchmarks.scala (100%)
rename benchmarks/src/{it =>
test}/scala/org/apache/pekko/kafka/benchmarks/NoCommitBackpressure.scala (100%)
rename benchmarks/src/{it =>
test}/scala/org/apache/pekko/kafka/benchmarks/PekkoConnectorsCommittableProducer.scala
(100%)
rename benchmarks/src/{it =>
test}/scala/org/apache/pekko/kafka/benchmarks/Producer.scala (100%)
rename benchmarks/src/{it =>
test}/scala/org/apache/pekko/kafka/benchmarks/SpecBase.scala (100%)
rename benchmarks/src/{it =>
test}/scala/org/apache/pekko/kafka/benchmarks/Transactions.scala (100%)
create mode 100644
core/src/main/mima-filters/2.0.x.backwards.excludes/remove-deprecated-code.excludes
rename {tests/src/it => int-tests/src/test}/resources/logback-test.xml (100%)
rename {tests/src/it => int-tests/src/test}/resources/reference.conf (100%)
rename {tests/src/it =>
int-tests/src/test}/scala/org/apache/pekko/kafka/IntegrationTests.scala (97%)
rename {tests/src/it =>
int-tests/src/test}/scala/org/apache/pekko/kafka/PartitionedSourceFailoverSpec.scala
(100%)
rename {tests/src/it =>
int-tests/src/test}/scala/org/apache/pekko/kafka/PlainSourceFailoverSpec.scala
(100%)
rename {tests/src/it =>
int-tests/src/test}/scala/org/apache/pekko/kafka/TransactionsPartitionedSourceSpec.scala
(100%)
rename {tests/src/it =>
int-tests/src/test}/scala/org/apache/pekko/kafka/TransactionsSourceSpec.scala
(100%)
copy
core/src/main/mima-filters/1.1.x.backwards.excludes/kafka-clients-4.0-upgrade.excludes
=>
testkit/src/main/mima-filters/1.1.x.backwards.excludes/docker-confluent-8.0-upgrade.excludes
(79%)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
