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 74bc4bb5 Update link-validator.conf
omit 1c8927ff java 17 build
omit f691296c Update protobuf-java to 4.33.0 (#387)
omit ddfe6e31 Update kafka-avro-serializer to 8.1.0 (#388)
omit 081990e4 Update scala3-library to 3.3.7
omit a3cf6392 Update sbt-source-dist to 0.1.13 (#381)
omit 4e7ef868 Update jupiter-interface, ... to 0.17.0
omit 414ece4a Update jupiter-interface, ... to 0.15.2
omit d9a65e9c Update kafka-avro-serializer to 8.0.2
omit e939ccf7 Update scala-library to 2.13.17
omit 677b0058 Update sbt, scripted-plugin to 1.11.7
omit 14a03e68 Update logback-classic to 1.5.19 (#378)
omit f54a36e2 Update junit jupiter to 6.0.0 (#380)
omit 54de2700 Update kafka-avro-serializer to 8.0.1 (#377)
omit b92d0593 Update sbt-license-report to 1.9.0 (#376)
omit 67a5cffb Kafka Client 4.1.0 (#358)
omit bde70d8a Update protobuf-java to 4.32.1 (#374)
omit c4033c20 Update logback-classic to 1.5.18 (#372)
omit 019094be Update jackson-databind to 2.20.0 (#373)
omit 05620a91 Update mockito-core to 5.20.0 (#375)
omit ea41fdd5 Clean up dependency version pinning in config (#370)
omit fc625a47 Remove some deprecated code (#369)
omit 10282b58 build with java 17 (#364)
omit 416d354f use scala converters (#367)
omit 541d44c9 drop Scala 2.12 support (#366)
omit 5965a14e protect 1.2.x branch (#365)
omit 6f20daf5 Update sbt-license-report to 1.8.0
omit 2244132c fix imports
omit 04391eb1 Update sbt-header to 5.11.0
omit de1e76e7 Update sbt, scripted-plugin to 1.11.6 (#357)
omit 3e629bb3 protect 1.1.x branch (#350)
omit 1a0388a3 support allowing to test with confluent v7 and v8 docker
images (#332)
omit 3fcf6dbc Update sbt, scripted-plugin to 1.11.5 (#354)
omit 96884d35 Update sbt-unidoc to 0.6.0 (#351)
omit 0c195ed0 Update scalapb-runtime to 0.11.20 (#352)
omit 0721402d Update sbt, scripted-plugin to 1.11.4 (#349)
omit 447a25cc Update jupiter-interface, ... to 0.15.1 (#348)
omit d47e0389 Update junit-jupiter-api to 5.13.4 (#347)
omit 08762349 Update commons-codec to 1.19.0 (#346)
omit 51b43681 pekko 1.1.5 (#345)
omit bc253867 Update sbt-pekko-build to 0.4.5 (#344)
omit 4e181bb0 Update sbt-scalafmt to 2.5.5 (#343)
omit add1c688 Update sbt, scripted-plugin to 1.11.3 (#342)
omit f04a392b Update junit-jupiter-api to 5.13.3 (#341)
omit 92c04ac8 Update scalapb-runtime to 0.11.19 (#337)
omit 72dfa7d5 Update sbt-pekko-build to 0.4.4 (#335)
omit 5f01091b Update sbt-dynver to 5.1.1 (#336)
omit fe5918c4 Update junit-jupiter-api to 5.13.2 (#338)
omit 32f0ad8d Update kafka to 1.21.3 (#340)
omit 26d73170 remove int-test usage (#333)
omit 2bfef29f upgrade jupiter-interface (#334)
omit 3a62e038 pekko 1.1.4 (#331)
omit caf3665f Update metrics-core to 4.2.33 (#329)
omit 7b63fe7d Update kafka to 1.21.2 (#330)
omit 363096fb Pin GitHub Actions (#327)
omit b8a53921 Update kafka-avro-serializer to 7.9.2 (#326)
omit f27d9792 Update junit-jupiter-api to 5.13.1 (#324)
omit 6b72eff3 Update sbt, scripted-plugin to 1.11.2 (#325)
omit 45990fbc Update scalapb-runtime to 0.11.18 (#323)
omit 6e28ecdf Update junit-jupiter-api to 5.13.0 (#319)
omit 13d5918e Update protobuf-java to 3.25.8 (#318)
omit 9e9bb1d3 Update kafka to 1.21.1 (#320)
omit a26e13ce Update kafka-clients to 3.9.1 (#315)
omit bce988d8 Update sbt, scripted-plugin to 1.11.0 (#316)
omit 26f261c7 Update metrics-core to 4.2.32 (#314)
omit 26887891 Update scala3-library to 3.3.6 (#313)
omit f5f2c325 Update kafka-avro-serializer to 7.9.1 (#312)
omit ce9578ef Update protobuf-java to 3.25.7 (#310)
omit 0ff8c646 Update kafka to 1.21.0 (#311)
omit 2957a88a test with confluent 7.9.0 docker images (#303)
omit 5c4e7d2b remove old ref for no longer existing config (#305)
omit 8c4eb816 Update sbt-java-formatter to 0.9.0 (#309)
omit 7671a8d0 pin sbt-java-formatter to 0.9.x (#308)
omit c6a01ccc Update junit-jupiter-api to 5.12.2 (#307)
omit 6ee76840 add testcontainers ref to license (#302)
omit 3dda6f4f test with latest available confluent images (#299)
omit 5d1e0836 doc: update kafka-client recommendation (#284)
omit 8a9fae12 remove caveat about bin compatibility (#298)
omit 386d14e2 Update sbt, scripted-plugin to 1.10.11 (#297)
new d94d8d36 Update kafka-clients to 4.0.0
new 04472902 try to fix compile issues
new fab3db74 Update KafkaConsumerActor.scala
new a281570c Update ConsumerResetProtection.scala
new c6d7ec3b Update KafkaSpec.scala
new 56ca1631 test compile issues
new 5842b517 Create kafka-clients-4.0-upgrade.excludes
new 0fca3707 deprecation issues
new 6ca1ef5a java 11 build
new b1f58007 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 (74bc4bb5)
\
N -- N -- N refs/heads/update/kafka-clients-4.0.0 (b1f58007)
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.
The 10 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
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/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
.../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 +-
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/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 | 19 ---
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 +-
.../src/it}/resources/logback-test.xml | 0
.../test => tests/src/it}/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
.../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, 904 insertions(+), 564 deletions(-)
rename benchmarks/src/{test =>
it}/scala/org/apache/pekko/kafka/benchmarks/BatchedConsumer.scala (100%)
rename benchmarks/src/{test =>
it}/scala/org/apache/pekko/kafka/benchmarks/Benchmarks.scala (100%)
rename benchmarks/src/{test =>
it}/scala/org/apache/pekko/kafka/benchmarks/NoCommitBackpressure.scala (100%)
rename benchmarks/src/{test =>
it}/scala/org/apache/pekko/kafka/benchmarks/PekkoConnectorsCommittableProducer.scala
(100%)
rename benchmarks/src/{test =>
it}/scala/org/apache/pekko/kafka/benchmarks/Producer.scala (100%)
rename benchmarks/src/{test =>
it}/scala/org/apache/pekko/kafka/benchmarks/SpecBase.scala (100%)
rename benchmarks/src/{test =>
it}/scala/org/apache/pekko/kafka/benchmarks/Transactions.scala (100%)
delete mode 100644
core/src/main/mima-filters/2.0.x.backwards.excludes/remove-deprecated-code.excludes
delete mode 100644
testkit/src/main/mima-filters/1.1.x.backwards.excludes/docker-confluent-8.0-upgrade.excludes
rename {int-tests/src/test => tests/src/it}/resources/logback-test.xml (100%)
rename {int-tests/src/test => tests/src/it}/resources/reference.conf (100%)
rename {int-tests/src/test =>
tests/src/it}/scala/org/apache/pekko/kafka/IntegrationTests.scala (97%)
rename {int-tests/src/test =>
tests/src/it}/scala/org/apache/pekko/kafka/PartitionedSourceFailoverSpec.scala
(100%)
rename {int-tests/src/test =>
tests/src/it}/scala/org/apache/pekko/kafka/PlainSourceFailoverSpec.scala (100%)
rename {int-tests/src/test =>
tests/src/it}/scala/org/apache/pekko/kafka/TransactionsPartitionedSourceSpec.scala
(100%)
rename {int-tests/src/test =>
tests/src/it}/scala/org/apache/pekko/kafka/TransactionsSourceSpec.scala (100%)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
