This is an automated email from the ASF dual-hosted git repository.
He-Pin pushed a change to branch doc
in repository https://gitbox.apache.org/repos/asf/pekko-connectors-kafka.git
discard 939b57a9 .
discard 7d553c91 chore: Add SendProducer#create method.
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 fb01b257 scala 2.13.18 (#394)
add 04c7da92 scalasteward update (#395)
add f0cbaf84 Remove pull_request trigger from link-validator workflow
(#396)
add b62358ca Update sbt-scalafmt to 2.5.6 (#405)
add 74e45c07 Update scalafmt-core to 3.9.10
add c6e9ee39 Reformat with scalafmt 3.9.10
add 3da48c33 Add 'Reformat with scalafmt 3.9.10' to .git-blame-ignore-revs
add 9472f76d Update logback-classic to 1.5.21 (#397)
add 6d0a1858 Update kafka-clients to 4.1.1 (#402)
add 201963d3 Update kafka-avro-serializer to 8.1.1 (#401)
add 5fb3fbd8 Update jackson-databind to 2.20.1 (#398)
add e897fecb Update junit-vintage-engine to 6.0.1 (#404)
add 8d9072d3 Update commons-codec to 1.20.0 (#400)
add 695cead7 Update protobuf-java to 4.33.1 (#399)
add 2663e943 Update scalafmt-core to 3.10.2 (#409)
add f6f1811c Update protobuf-java to 4.33.2 (#408)
add 1ea4a731 build with 2.0.0-M1 (#393)
add aacc1b3d github job to update our CI actions (#407)
add 547aff62 Bump actions/checkout from 4.2.2 to 6.0.1 (#411)
add d2917d9d Bump scala-steward-org/scala-steward-action from 2.77.0 to
2.78.0 (#414)
add 3bc60908 Bump sbt/setup-sbt from 1.1.9 to 1.1.14 (#413)
add 71b98fe8 Bump actions/setup-java from 4.7.1 to 5.1.0 (#410)
add ab241eb5 Bump coursier/cache-action from 6.4.9 to 7.0.0 (#412)
add 4c6703ba Remove deprecated Apache StringUtils
add bf7cb279 Update mockito-core to 5.21.0
add 5792f10e Update sbt-pekko-build to 0.4.7
add eb7096bc Update logback-classic to 1.5.22
add adb1287f Bump actions/cache from 4.2.3 to 5.0.1 (#420)
add 1936f814 Bump coursier/setup-action from 1.3.9 to 2.0.1 (#419)
add c50d7bad Update kafka to 1.21.4 (#421)
add 340fbbf0 Update scalafmt-core to 3.10.3 (#423)
add 9877824a Update logback-classic to 1.5.23 (#422)
add 30ac531a Bump coursier/setup-action from 2.0.1 to 2.0.2 (#424)
add 8b244bb0 change to 2026 in copyright (#426)
add 045f57af Update logback-classic to 1.5.24 (#427)
add f2b08282 Update sbt, scripted-plugin to 1.12.0 (#431)
add 3ea808a7 Update junit-jupiter-api to 6.0.2 (#430)
add 0e64a76f Update protobuf-java to 4.33.3 (#429)
add a5c74e68 Update sbt-unidoc to 0.6.1 (#428)
add 465594e4 Bump sbt/setup-sbt from 1.1.14 to 1.1.15 (#432)
add 3cab2b86 Update protobuf-java to 4.33.4 (#435)
add 7de28c8f Update logback-classic to 1.5.25
add 0378e939 Update scalafmt-core to 3.10.4
add f6aff22f Reformat with scalafmt 3.10.4
add 0cec0d1e Add 'Reformat with scalafmt 3.10.4' to .git-blame-ignore-revs
add 942387c0 Bump actions/cache from 5.0.1 to 5.0.2 (#438)
add 182085bc Bump actions/checkout from 6.0.1 to 6.0.2 (#441)
add 76dab3db Bump actions/setup-java from 5.1.0 to 5.2.0 (#440)
add 470d39ab Update logback-classic to 1.5.26 (#443)
add d431a79c Update scalafmt-core to 3.10.5
add 183d00ee Reformat with scalafmt 3.10.5
add 1685b5b9 Add 'Reformat with scalafmt 3.10.5' to .git-blame-ignore-revs
add d897b8b4 Update sbt, scripted-plugin to 1.12.1 (#445)
add 50134813 Update jackson-databind to 2.20.2 (#444)
add e5cbd35d Update scalafmt-core to 3.10.6
add fc298b97 Update commons-codec to 1.21.0
add aef5cf50 Update protobuf-java to 4.33.5
add 9c7209a9 Update jackson-databind to 2.21.0 (#448)
add a486788c Update logback-classic to 1.5.27 (#447)
add a70f1441 Bump scala-steward-org/scala-steward-action from 2.78.0 to
2.81.0
add 5d1fab24 Update sbt-java-formatter to 0.10.0
add 06b7d8ed chore: update .git-blame-ignore-revs
add 59fa3659 Update sbt, scripted-plugin to 1.12.2 (#455)
add 2eba89fe Update logback-classic to 1.5.29 (#459)
add a59c7227 Update junit-jupiter-api to 6.0.3 (#463)
add 477cd854 Update logback-classic to 1.5.32 (#462)
add d543479c Update sbt, scripted-plugin to 1.12.3 (#464)
add 128dfb13 Update scalafmt-core to 3.10.7 (#460)
add 35105a5a Bump sbt/setup-sbt from 1.1.15 to 1.1.16 (#453)
add 6df0883b Bump actions/cache from 5.0.2 to 5.0.3 (#452)
add c9097f3d Bump coursier/cache-action from 7.0.0 to 8.0.0 (#458)
add 8f618859 Update sbt-mima-plugin to 1.1.5 (#465)
add e5a527ec Update sbt, scripted-plugin to 1.12.4 (#472)
add 56a1a710 Bump coursier/cache-action from 8.0.0 to 8.0.1 (#470)
add d70cb014 Bump sbt/setup-sbt from 1.1.16 to 1.1.17 (#469)
add 480a2017 Bump coursier/setup-action from 2.0.2 to 2.0.3 (#468)
add d07f037c Update jackson-databind to 2.21.1 (#471)
add 44884f6d Delete scala-steward.yml (#474)
add 96ea120a Update mockito-core to 5.22.0 (#476)
add 881b10e6 Update protobuf-java to 4.34.0 (#475)
add b058f7f2 Bump sbt/setup-sbt from 1.1.17 to 1.1.18 (#477)
add 707961b5 Update sbt, scripted-plugin to 1.12.5 (#478)
add 1733ec4f Update kafka-avro-serializer to 8.2.0 (#479)
add c37fca37 Bump sbt/setup-sbt from 1.1.18 to 1.1.19 (#480)
add f4933f19 Update sbt, scripted-plugin to 1.12.6 (#483)
add 32dde2af Update protobuf-java to 4.34.1 (#486)
add 28262704 Update jackson-databind to 2.21.2 (#485)
add d72b5bfe Update jupiter-interface, ... to 0.17.1 (#482)
add 90d2cfbe Bump coursier/setup-action from 2.0.3 to 3.0.0 (#487)
add a0f810d8 Bump actions/cache from 5.0.3 to 5.0.4 (#490)
add ebb72194 Bump sbt/setup-sbt from 1.1.19 to 1.1.20 (#489)
add d8e35fcc Update mockito-core to 5.23.0 (#481)
add 88e0fa76 Update kafka-clients to 4.1.2 (#484)
add d4734f8a Bump coursier/cache-action from 8.0.1 to 8.1.0 (#488)
add 737f2e05 Update jupiter-interface, ... to 0.18.0 (#492)
add 4c936049 Update sbt, scripted-plugin to 1.12.8 (#494)
add 24b6fdcf Update scalatest to 3.2.20 (#495)
add 18be4209 Bump sbt/setup-sbt from 1.1.20 to 1.1.22 (#498)
add 3108abe2 Remove fruitless rewrite rule (#497)
add 8b39a670 Bump jrouly/scalafmt-native-action from 4 to 5 (#500)
add 1306d38b Update sbt-java-formatter to 0.11.0 (#499)
add 4744b1b0 Address link to java.time.Duration$ in scaladoc (#496)
add ba6b1530 Add mockito as an agent (#491)
add 9d879177 Update sbt, scripted-plugin to 1.12.9 (#501)
add a4f3d52b only run nightly on main repo (#502)
add a4a5a05b Update sbt-scalafmt to 2.6.0 (#503)
add e103c2a9 Update scalafmt-core to 3.11.0 (#504)
add 398b44f2 Retry committing for transient exceptions (#505)
add e7f15e33 Allow simpler access to partition assignment strategies (#506)
add 0f9c11b7 Separate csv formatting files and components (#508)
add a8143043 Use new ExternalShardAllocationStrategy api in examples (#509)
add 231b3385 Bump actions/cache from 5.0.4 to 5.0.5 (#510)
add c4503bd1 Update Maven Central links in README.md (#511)
add bbef8d7a Create stage-release-candidate.yml (#512)
add 1b20bd5f 2.0.0-M1 release notes (#513)
add 1bc3f176 Update commons-codec to 1.22.0 (#516)
add 7969d60c Update sbt, scripted-plugin to 1.12.10 (#517)
add ba80d0cd Update jackson-databind to 2.21.3 (#518)
add c6b805a8 Update sbt, scripted-plugin to 1.12.11 (#519)
add 197b6cbf Update sbt-java-formatter to 0.12.0
add e8d6e58e Reformat with sbt-java-formatter 0.12.0
add 8071d1e2 Update jul-to-slf4j, log4j-over-slf4j to 2.0.18 (#525)
add 0bba172f Update jupiter-interface, ... to 0.19.0 (#522)
add f353de33 Update sbt-scalafmt to 2.6.1 (#523)
add 37b19d43 Update scalafmt-core to 3.11.1 (#524)
add 3b2601f7 Update kafka-avro-serializer to 8.2.1 (#526)
add 69e43a5e remove use of cache action (#528)
add 34ec44ff Update junit-vintage-engine to 6.1.0 (#531)
add 54ec2811 Update junit-jupiter-api to 6.1.0 (#530)
add eccaa839 Update protobuf-java to 4.35.0 (#529)
add 751bfca5 Bump sbt/setup-sbt from 1.1.22 to 1.1.24 (#533)
add 52fa5ba7 Update kafka-clients to 4.3.0 (#532)
add eece12d5 try to remove junit-vintage-engine dep (#534)
add c78cbdc2 fix deprecation issues with kafka client calls (#535)
add 13e09313 regenerate OrderMessages.java (#536)
add da60df51 Bump sbt/setup-sbt from 1.1.24 to 1.2.1 (#540)
add b79808f7 Update pekko to 2.0.0-M3 (#539)
add 8b623e91 Update jackson-databind to 2.21.4 (#538)
add 495758d4 Update logback-classic to 1.5.34 (#541)
add e20f1e68 Update jackson-databind to 2.22.0 (#542)
add 360053d8 Bump actions/checkout from 6.0.2 to 6.0.3 (#543)
add 6c6ff135 Update protobuf-java to 4.35.1 (#544)
add 06c4b124 Update scala3-library to 3.3.8 (#545)
add d7e1cc58 Add -Yfuture-lazy-vals for Scala 3.3.x builds (#546)
add cf7692cd Update sbt-api-mappings to 3.0.3 (#549)
add 0680feb3 Update sbt, scripted-plugin to 1.12.12 (#550)
add 68d87b3d feat: improve Scala 3.8 forward compatibility (#552)
add 2ab742fe chore: Add SendProducer#create method.
add ab4d36b8 .
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 (939b57a9)
\
N -- N -- N refs/heads/doc (ab4d36b8)
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 | 12 +
.git-blame-ignore-revs | 12 +
.github/dependabot.yml | 6 +
.github/workflows/check-build-test.yml | 83 ++---
.github/workflows/format.yml | 4 +-
.github/workflows/headers.yml | 13 +-
.github/workflows/link-validator.yml | 17 +-
.github/workflows/nightly-pekko.yml | 30 +-
.github/workflows/publish-1.0-docs.yml | 9 +-
.github/workflows/publish-1.1-docs.yml | 10 +-
.../{publish-1.1-docs.yml => publish-2.0-docs.yml} | 37 +--
.github/workflows/publish-nightly.yml | 13 +-
.github/workflows/scala-steward.yml | 20 --
.github/workflows/stage-release-candidate.yml | 354 +++++++++++++++++++++
.sbtopts | 10 +
.scala-steward.conf | 13 -
.scalafmt.conf | 2 +-
NOTICE | 2 +-
README.md | 4 +-
.../pekko/kafka/benchmarks/CsvFormatter.scala | 25 +-
.../pekko/kafka/benchmarks/CsvFormatting.scala | 56 ++++
.../{FixtureGen.scala => CsvQuotingStyle.scala} | 11 +-
.../pekko/kafka/benchmarks/InflightMetrics.scala | 4 +-
.../kafka/benchmarks/KafkaConsumerBenchmarks.scala | 2 +-
.../kafka/benchmarks/KafkaConsumerFixtureGen.scala | 3 +-
.../benchmarks/KafkaTransactionBenchmarks.scala | 8 +-
.../benchmarks/KafkaTransactionFixtureGen.scala | 3 +-
.../ReactiveKafkaConsumerBenchmarks.scala | 3 +-
.../org/apache/pekko/kafka/benchmarks/Timed.scala | 28 +-
build.sbt | 15 +-
.../cluster/sharding/KafkaClusterSharding.scala | 10 +-
.../kafka-clients-4.0-upgrade.excludes | 4 +-
.../remove-deprecated-code.excludes | 41 +++
.../org/apache/pekko/kafka/CommitterSettings.scala | 7 +-
.../pekko/kafka/ConnectionCheckerSettings.scala | 10 +-
.../org/apache/pekko/kafka/ConsumerMessage.scala | 21 +-
.../org/apache/pekko/kafka/ConsumerSettings.scala | 109 ++++---
.../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 | 31 +-
.../apache/pekko/kafka/RestrictedConsumer.scala | 6 -
.../org/apache/pekko/kafka/Subscriptions.scala | 10 +-
.../kafka/internal/BaseSingleSourceLogic.scala | 7 +-
.../kafka/internal/CommitObservationLogic.scala | 3 +-
.../pekko/kafka/internal/CommittableSources.scala | 5 +-
.../pekko/kafka/internal/ConfigSettings.scala | 8 +-
.../kafka/internal/ConsumerProgressTracking.scala | 35 +-
.../kafka/internal/ConsumerResetProtection.scala | 4 +-
.../kafka/internal/ControlImplementations.scala | 9 +-
.../kafka/internal/DefaultProducerStage.scala | 2 +-
.../pekko/kafka/internal/DeferredProducer.scala | 11 +-
.../pekko/kafka/internal/KafkaConsumerActor.scala | 64 ++--
.../pekko/kafka/internal/LoggingWithId.scala | 4 +-
.../pekko/kafka/internal/MessageBuilder.scala | 23 +-
.../internal/PartitionAssignmentHelpers.scala | 2 +-
.../pekko/kafka/internal/SingleSourceLogic.scala | 2 +-
.../pekko/kafka/internal/SubSourceLogic.scala | 10 +-
.../internal/TransactionalProducerStage.scala | 5 +-
.../kafka/internal/TransactionalSources.scala | 25 +-
.../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 | 4 +-
.../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 | 49 ++-
.../org/apache/pekko/kafka/scaladsl/Producer.scala | 158 ---------
.../apache/pekko/kafka/scaladsl/SendProducer.scala | 9 +-
docs/src/main/paradox/consumer.md | 3 +
docs/src/main/paradox/release-notes/index.md | 1 +
.../src/main/paradox/release-notes/releases-2.0.md | 13 +
docs/src/main/paradox/serialization.md | 10 +-
.../org/apache/pekko/kafka/IntegrationTests.scala | 3 +-
.../kafka/TransactionsPartitionedSourceSpec.scala | 10 +-
.../pekko/kafka/TransactionsSourceSpec.scala | 13 +-
.../src/test/java/docs/javadsl/AssignmentTest.java | 28 +-
.../java/docs/javadsl/ClusterShardingExample.java | 6 +-
.../java/docs/javadsl/ConsumerExampleTest.java | 63 ++--
.../java/docs/javadsl/ConsumerSettingsTest.java | 24 +-
.../test/java/docs/javadsl/MetadataClientTest.java | 35 +-
.../java/docs/javadsl/ProducerSettingsTest.java | 4 +-
.../src/test/java/docs/javadsl/ProducerTest.java | 37 +--
.../javadsl/SchemaRegistrySerializationTest.java | 47 ++-
.../test/java/docs/javadsl/SerializationTest.java | 45 ++-
.../test/java/docs/javadsl/TestkitSamplesTest.java | 12 +-
.../java/docs/javadsl/proto/OrderMessages.java | 141 ++++----
legal/PekkoKafkaNotice.txt | 2 +-
project/CopyrightHeader.scala | 12 +-
project/Dependencies.scala | 9 +-
project/ParadoxSettings.scala | 9 +-
project/PekkoCoreDependency.scala | 2 +-
project/ProjectSettings.scala | 25 +-
project/Versions.scala | 18 +-
project/build.properties | 2 +-
project/plugins.sbt | 24 +-
project/project-info.conf | 2 +-
scripts/link-validator.conf | 3 +-
.../org/apache/pekko/kafka/testkit/KafkaTest.java | 11 -
.../testkit/TestcontainersKafkaJunit4Test.java | 11 -
.../kafka/testkit/TestcontainersKafkaTest.java | 10 -
.../pekko/kafka/testkit/javadsl/BaseKafkaTest.java | 18 +-
.../kafka/testkit/javadsl/KafkaJunit4Test.java | 11 -
.../KafkaTestkitTestcontainersSettings.scala | 17 +-
.../kafka/testkit/ProducerResultFactory.scala | 2 +-
.../kafka/testkit/internal/KafkaTestKit.scala | 5 +-
.../testkit/internal/TestcontainersKafka.scala | 15 +-
.../pekko/kafka/testkit/scaladsl/KafkaSpec.scala | 10 +-
.../docs/scaladsl/ClusterShardingExample.scala | 2 +-
.../test/scala/docs/scaladsl/FetchMetadata.scala | 4 +-
.../scaladsl/SchemaRegistrySerializationSpec.scala | 18 +-
.../src/test/scala/docs/scaladsl/proto/Order.scala | 6 +-
.../scala/docs/scaladsl/proto/OrderProto.scala | 2 -
.../apache/pekko/kafka/ConsumerSettingsSpec.scala | 38 +++
.../org/apache/pekko/kafka/TransactionsOps.scala | 9 +-
.../kafka/internal/CommitCollectorStageSpec.scala | 20 +-
.../internal/CommittingProducerSinkSpec.scala | 36 +--
.../kafka/internal/CommittingWithMockSpec.scala | 36 ++-
.../pekko/kafka/internal/ConsumerDummy.scala | 15 +-
.../apache/pekko/kafka/internal/ConsumerMock.scala | 12 +-
.../internal/ConsumerProgressTrackingSpec.scala | 6 +-
.../internal/ConsumerResetProtectionSpec.scala | 10 +-
.../apache/pekko/kafka/internal/ConsumerSpec.scala | 24 +-
.../kafka/internal/PartitionedSourceSpec.scala | 58 ++--
.../apache/pekko/kafka/internal/ProducerSpec.scala | 100 +++---
.../apache/pekko/kafka/javadsl/ControlSpec.scala | 2 +-
.../pekko/kafka/scaladsl/CommittingSpec.scala | 20 +-
.../kafka/scaladsl/ConnectionCheckerSpec.scala | 5 +-
.../pekko/kafka/scaladsl/IntegrationSpec.scala | 14 +-
.../kafka/scaladsl/PartitionedSourcesSpec.scala | 8 +-
.../pekko/kafka/scaladsl/RebalanceExtSpec.scala | 3 +-
.../pekko/kafka/scaladsl/RebalanceSpec.scala | 12 +-
.../pekko/kafka/scaladsl/RetentionPeriodSpec.scala | 14 +-
.../pekko/kafka/scaladsl/TimestampSpec.scala | 8 +-
.../pekko/kafka/scaladsl/TransactionsSpec.scala | 21 +-
.../pekko/kafka/tests/CapturingAppender.scala | 4 +-
.../org/apache/pekko/kafka/tests/LogbackUtil.scala | 4 +-
141 files changed, 1560 insertions(+), 1444 deletions(-)
create mode 100644 .github/dependabot.yml
copy .github/workflows/{publish-1.1-docs.yml => publish-2.0-docs.yml} (70%)
delete mode 100644 .github/workflows/scala-steward.yml
create mode 100644 .github/workflows/stage-release-candidate.yml
create mode 100644 .sbtopts
create mode 100644
benchmarks/src/main/scala/org/apache/pekko/kafka/benchmarks/CsvFormatting.scala
copy
benchmarks/src/main/scala/org/apache/pekko/kafka/benchmarks/{FixtureGen.scala
=> CsvQuotingStyle.scala} (66%)
copy
testkit/src/main/mima-filters/1.1.x.backwards.excludes/docker-confluent-8.0-upgrade.excludes
=>
core/src/main/mima-filters/1.1.x.backwards.excludes/kafka-clients-4.0-upgrade.excludes
(79%)
create mode 100644
core/src/main/mima-filters/2.0.x.backwards.excludes/remove-deprecated-code.excludes
create mode 100644 docs/src/main/paradox/release-notes/releases-2.0.md
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
