This is an automated email from the ASF dual-hosted git repository.
mdedetrich pushed a change to branch main
in repository
https://gitbox.apache.org/repos/asf/incubator-pekko-connectors-kafka.git
from 96a09210 drop private return type
new a4500c8e Update scalafmt
new 667c4dba Add .gitattributes to enforce unix line endings
new cceccdcd format source with scalafmt, #9
The 3 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:
.gitattributes | 5 +
.scalafmt.conf | 90 ++++++-
.../benchmarks/AlpakkaCommittableProducer.scala | 14 +-
.../akka/kafka/benchmarks/BatchedConsumer.scala | 30 +--
.../scala/akka/kafka/benchmarks/Benchmarks.scala | 33 ++-
.../kafka/benchmarks/NoCommitBackpressure.scala | 8 +-
.../it/scala/akka/kafka/benchmarks/Producer.scala | 2 +-
.../it/scala/akka/kafka/benchmarks/SpecBase.scala | 2 +-
.../scala/akka/kafka/benchmarks/Transactions.scala | 16 +-
.../AlpakkaCommittableSinkFixtures.scala | 47 ++--
.../akka/kafka/benchmarks/InflightMetrics.scala | 65 +++--
.../kafka/benchmarks/KafkaConsumerBenchmarks.scala | 11 +-
.../kafka/benchmarks/KafkaConsumerFixtureGen.scala | 10 +-
.../kafka/benchmarks/KafkaProducerBenchmarks.scala | 5 +-
.../kafka/benchmarks/KafkaProducerFixtureGen.scala | 14 +-
.../benchmarks/KafkaTransactionBenchmarks.scala | 14 +-
.../benchmarks/KafkaTransactionFixtureGen.scala | 26 +-
.../akka/kafka/benchmarks/PerfFixtureHelpers.scala | 18 +-
.../ReactiveKafkaConsumerBenchmarks.scala | 29 ++-
.../benchmarks/ReactiveKafkaConsumerFixtures.scala | 21 +-
.../ReactiveKafkaProducerBenchmarks.scala | 4 +-
.../benchmarks/ReactiveKafkaProducerFixtures.scala | 18 +-
.../ReactiveKafkaTransactionBenchmarks.scala | 10 +-
.../ReactiveKafkaTransactionFixtures.scala | 35 ++-
.../main/scala/akka/kafka/benchmarks/Timed.scala | 15 +-
build.sbt | 266 ++++++++++-----------
.../cluster/sharding/KafkaClusterSharding.scala | 75 +++---
.../main/scala/akka/kafka/CommitterSettings.scala | 20 +-
.../akka/kafka/ConnectionCheckerSettings.scala | 17 +-
.../src/main/scala/akka/kafka/ConsumerFailed.scala | 6 +-
.../main/scala/akka/kafka/ConsumerMessage.scala | 16 +-
.../main/scala/akka/kafka/ConsumerSettings.scala | 80 +++----
.../main/scala/akka/kafka/KafkaConsumerActor.scala | 4 +-
core/src/main/scala/akka/kafka/Metadata.scala | 4 +-
.../akka/kafka/OffsetResetProtectionSettings.scala | 10 +-
.../main/scala/akka/kafka/ProducerMessage.scala | 35 +--
.../main/scala/akka/kafka/ProducerSettings.scala | 102 ++++----
.../main/scala/akka/kafka/RestrictedConsumer.scala | 6 +-
core/src/main/scala/akka/kafka/Subscriptions.scala | 10 +-
.../kafka/internal/BaseSingleSourceLogic.scala | 24 +-
.../akka/kafka/internal/CommitCollectorStage.scala | 14 +-
.../kafka/internal/CommitObservationLogic.scala | 13 +-
.../akka/kafka/internal/CommittableSources.scala | 103 ++++----
.../internal/CommittingProducerSinkStage.scala | 41 ++--
.../scala/akka/kafka/internal/ConfigSettings.scala | 8 +-
.../akka/kafka/internal/ConnectionChecker.scala | 20 +-
.../kafka/internal/ConsumerProgressTracking.scala | 52 ++--
.../kafka/internal/ConsumerResetProtection.scala | 37 ++-
.../kafka/internal/ControlImplementations.scala | 18 +-
.../akka/kafka/internal/DefaultProducerStage.scala | 28 +--
.../akka/kafka/internal/DeferredProducer.scala | 5 +-
.../kafka/internal/ExternalSingleSourceLogic.scala | 3 +-
.../akka/kafka/internal/KafkaConsumerActor.scala | 80 +++----
.../akka/kafka/internal/KafkaSourceStage.scala | 2 +-
.../scala/akka/kafka/internal/LoggingWithId.scala | 4 +-
.../scala/akka/kafka/internal/MessageBuilder.scala | 50 ++--
.../internal/PartitionAssignmentHelpers.scala | 8 +-
.../scala/akka/kafka/internal/PlainSources.scala | 40 ++--
.../akka/kafka/internal/SingleSourceLogic.scala | 27 +--
.../akka/kafka/internal/SourceLogicBuffer.scala | 2 +-
.../kafka/internal/SourceLogicSubscription.scala | 25 +-
.../scala/akka/kafka/internal/SubSourceLogic.scala | 84 +++----
.../internal/TransactionalProducerStage.scala | 60 +++--
.../akka/kafka/internal/TransactionalSources.scala | 108 ++++-----
.../main/scala/akka/kafka/javadsl/Committer.scala | 14 +-
.../main/scala/akka/kafka/javadsl/Consumer.scala | 93 ++++---
.../akka/kafka/javadsl/DiscoverySupport.scala | 20 +-
.../scala/akka/kafka/javadsl/MetadataClient.scala | 21 +-
.../main/scala/akka/kafka/javadsl/Producer.scala | 44 ++--
.../scala/akka/kafka/javadsl/SendProducer.scala | 6 +-
.../scala/akka/kafka/javadsl/Transactional.scala | 29 +--
.../main/scala/akka/kafka/scaladsl/Committer.scala | 9 +-
.../main/scala/akka/kafka/scaladsl/Consumer.scala | 63 +++--
.../akka/kafka/scaladsl/DiscoverySupport.scala | 26 +-
.../scala/akka/kafka/scaladsl/MetadataClient.scala | 30 ++-
.../main/scala/akka/kafka/scaladsl/Producer.scala | 73 +++---
.../scala/akka/kafka/scaladsl/SendProducer.scala | 16 +-
.../scala/akka/kafka/scaladsl/Transactional.scala | 47 ++--
project/AutomaticModuleName.scala | 5 +-
project/VersionGenerator.scala | 11 +-
.../akka/kafka/testkit/ConsumerResultFactory.scala | 27 +--
.../akka/kafka/testkit/KafkaTestkitSettings.scala | 4 +-
.../KafkaTestkitTestcontainersSettings.scala | 73 +++---
.../akka/kafka/testkit/ProducerResultFactory.scala | 32 ++-
.../akka/kafka/testkit/internal/KafkaTestKit.scala | 20 +-
.../testkit/internal/KafkaTestKitChecks.scala | 45 ++--
.../testkit/internal/TestFrameworkInterface.scala | 2 +-
.../testkit/internal/TestcontainersKafka.scala | 11 +-
.../testkit/javadsl/ConsumerControlFactory.scala | 11 +-
.../testkit/scaladsl/ConsumerControlFactory.scala | 8 +-
.../akka/kafka/testkit/scaladsl/KafkaSpec.scala | 38 ++-
.../testkit/scaladsl/ScalatestKafkaSpec.scala | 3 +-
.../testkit/scaladsl/TestcontainersKafkaLike.scala | 2 +-
.../src/it/scala/akka/kafka/IntegrationTests.scala | 3 +-
.../akka/kafka/PartitionedSourceFailoverSpec.scala | 13 +-
.../scala/akka/kafka/PlainSourceFailoverSpec.scala | 13 +-
.../kafka/TransactionsPartitionedSourceSpec.scala | 46 ++--
.../scala/akka/kafka/TransactionsSourceSpec.scala | 51 ++--
.../test/scala/akka/kafka/ConfigSettingsSpec.scala | 3 +-
.../scala/akka/kafka/ConsumerSettingsSpec.scala | 47 ++--
.../scala/akka/kafka/ProducerSettingsSpec.scala | 47 ++--
tests/src/test/scala/akka/kafka/Repeated.scala | 2 +-
.../test/scala/akka/kafka/TransactionsOps.scala | 62 +++--
.../kafka/internal/CommitCollectorStageSpec.scala | 103 ++++----
.../internal/CommittingProducerSinkSpec.scala | 156 +++++-------
.../kafka/internal/CommittingWithMockSpec.scala | 76 +++---
.../kafka/internal/ConnectionCheckerSpec.scala | 4 +-
.../scala/akka/kafka/internal/ConsumerDummy.scala | 26 +-
.../scala/akka/kafka/internal/ConsumerMock.scala | 8 +-
.../internal/ConsumerProgressTrackingSpec.scala | 10 +-
.../internal/ConsumerResetProtectionSpec.scala | 65 +++--
.../scala/akka/kafka/internal/ConsumerSpec.scala | 42 ++--
.../kafka/internal/OffsetAggregationSpec.scala | 9 +-
.../kafka/internal/PartitionedSourceSpec.scala | 49 ++--
.../scala/akka/kafka/internal/ProducerSpec.scala | 92 ++++---
.../akka/kafka/internal/SubscriptionsSpec.scala | 22 +-
.../scala/akka/kafka/javadsl/ControlSpec.scala | 12 +-
.../akka/kafka/scaladsl/CommittableSinkSpec.scala | 10 +-
.../scala/akka/kafka/scaladsl/CommittingSpec.scala | 101 +++-----
.../kafka/scaladsl/ConnectionCheckerSpec.scala | 2 +-
.../scala/akka/kafka/scaladsl/ControlSpec.scala | 4 +-
.../akka/kafka/scaladsl/IntegrationSpec.scala | 23 +-
.../akka/kafka/scaladsl/MetadataClientSpec.scala | 2 +-
.../kafka/scaladsl/MisconfiguredConsumerSpec.scala | 4 +-
.../kafka/scaladsl/MisconfiguredProducerSpec.scala | 2 +-
.../akka/kafka/scaladsl/MultiConsumerSpec.scala | 14 +-
.../kafka/scaladsl/PartitionedSourcesSpec.scala | 51 ++--
.../akka/kafka/scaladsl/RebalanceExtSpec.scala | 108 ++++-----
.../scala/akka/kafka/scaladsl/RebalanceSpec.scala | 63 ++---
.../scala/akka/kafka/scaladsl/ReconnectSpec.scala | 10 +-
.../akka/kafka/scaladsl/RetentionPeriodSpec.scala | 8 +-
.../test/scala/akka/kafka/scaladsl/SpecBase.scala | 2 +-
.../akka/kafka/scaladsl/TransactionsSpec.scala | 77 +++---
.../scala/akka/kafka/tests/CapturingAppender.scala | 3 +-
.../test/scala/akka/kafka/tests/LogbackUtil.scala | 7 +-
.../tests/javadsl/LogCapturingExtension.scala | 8 +-
.../kafka/tests/javadsl/LogCapturingJunit4.scala | 3 +-
.../akka/kafka/tests/scaladsl/LogCapturing.scala | 6 +-
.../test/scala/docs/scaladsl/AssignmentSpec.scala | 9 +-
.../src/test/scala/docs/scaladsl/AtLeastOnce.scala | 53 ++--
.../docs/scaladsl/ClusterShardingExample.scala | 18 +-
.../test/scala/docs/scaladsl/ConsumerExample.scala | 43 ++--
.../test/scala/docs/scaladsl/DocsSpecBase.scala | 2 +-
.../test/scala/docs/scaladsl/FetchMetadata.scala | 10 +-
.../scala/docs/scaladsl/PartitionExamples.scala | 36 ++-
.../test/scala/docs/scaladsl/ProducerExample.scala | 36 ++-
.../scaladsl/SchemaRegistrySerializationSpec.scala | 25 +-
.../scala/docs/scaladsl/SendProducerSpec.scala | 19 +-
.../scala/docs/scaladsl/SerializationSpec.scala | 11 +-
.../scala/docs/scaladsl/TestkitSamplesSpec.scala | 29 +--
.../scala/docs/scaladsl/TransactionsExample.scala | 16 +-
.../src/test/scala/docs/scaladsl/proto/Order.scala | 23 +-
.../scala/docs/scaladsl/proto/OrderProto.scala | 13 +-
153 files changed, 2076 insertions(+), 2568 deletions(-)
create mode 100644 .gitattributes
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
