You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pekko.apache.org by fa...@apache.org on 2023/02/04 11:18:25 UTC
[incubator-pekko-connectors-kafka] branch main updated: Update scalafmt (#16)
This is an automated email from the ASF dual-hosted git repository.
fanningpj pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/incubator-pekko-connectors-kafka.git
The following commit(s) were added to refs/heads/main by this push:
new 52b0a4eb Update scalafmt (#16)
52b0a4eb is described below
commit 52b0a4eba3883060a3001edc2c49915188ba8bc1
Author: Matthew de Detrich <ma...@aiven.io>
AuthorDate: Sat Feb 4 12:18:20 2023 +0100
Update scalafmt (#16)
* Update scalafmt
* Revert removal of return function type in streamProbesWithOffsetFactory
---
.github/workflows/format.yml | 2 +-
.scalafmt.conf | 2 +-
.../src/test/scala/akka/kafka/internal/CommitCollectorStageSpec.scala | 4 +++-
3 files changed, 5 insertions(+), 3 deletions(-)
diff --git a/.github/workflows/format.yml b/.github/workflows/format.yml
index 502401a8..9d330b61 100644
--- a/.github/workflows/format.yml
+++ b/.github/workflows/format.yml
@@ -20,5 +20,5 @@ jobs:
- name: Check project is formatted
uses: jrouly/scalafmt-native-action@v2
with:
- version: '3.6.1'
+ version: '3.7.1'
arguments: '--list --mode diff-ref=origin/main'
diff --git a/.scalafmt.conf b/.scalafmt.conf
index efa297ee..1aae8a44 100644
--- a/.scalafmt.conf
+++ b/.scalafmt.conf
@@ -1,4 +1,4 @@
-version = 3.6.1
+version = 3.7.1
runner.dialect = scala213
project.git = true
style = defaultWithAlign
diff --git a/tests/src/test/scala/akka/kafka/internal/CommitCollectorStageSpec.scala b/tests/src/test/scala/akka/kafka/internal/CommitCollectorStageSpec.scala
index 7c495d42..24c68561 100644
--- a/tests/src/test/scala/akka/kafka/internal/CommitCollectorStageSpec.scala
+++ b/tests/src/test/scala/akka/kafka/internal/CommitCollectorStageSpec.scala
@@ -408,7 +408,9 @@ class CommitCollectorStageSpec(_system: ActorSystem)
}
private def streamProbesWithOffsetFactory(
- committerSettings: CommitterSettings) = {
+ committerSettings: CommitterSettings): (TestPublisher.Probe[Committable],
+ Consumer.Control,
+ TestSubscriber.Probe[CommittableOffsetBatch], TestOffsetFactory) = {
val (source, control, sink) = streamProbes(committerSettings)
val factory = TestOffsetFactory(new TestBatchCommitter(committerSettings))
(source, control, sink, factory)
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@pekko.apache.org
For additional commands, e-mail: commits-help@pekko.apache.org