You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pekko.apache.org by gi...@apache.org on 2025/12/03 13:58:20 UTC
(pekko-connectors-kafka) branch update/scalafmt-core-3.9.10 created (now 64d922ac)
This is an automated email from the ASF dual-hosted git repository.
github-bot pushed a change to branch update/scalafmt-core-3.9.10
in repository https://gitbox.apache.org/repos/asf/pekko-connectors-kafka.git
at 64d922ac Add 'Reformat with scalafmt 3.9.10' to .git-blame-ignore-revs
This branch includes the following new commits:
new cab30c9e Update scalafmt-core to 3.9.10
new 505a5761 Reformat with scalafmt 3.9.10
new 64d922ac Add 'Reformat with scalafmt 3.9.10' to .git-blame-ignore-revs
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.
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@pekko.apache.org
For additional commands, e-mail: commits-help@pekko.apache.org
(pekko-connectors-kafka) 03/03: Add 'Reformat with scalafmt 3.9.10' to .git-blame-ignore-revs
Posted by gi...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
github-bot pushed a commit to branch update/scalafmt-core-3.9.10
in repository https://gitbox.apache.org/repos/asf/pekko-connectors-kafka.git
commit 64d922ac2073e178b9aafdfe12f860691cfcfce2
Author: scala-steward-asf[bot] <14...@users.noreply.github.com>
AuthorDate: Wed Dec 3 13:58:15 2025 +0000
Add 'Reformat with scalafmt 3.9.10' to .git-blame-ignore-revs
---
.git-blame-ignore-revs | 3 +++
1 file changed, 3 insertions(+)
diff --git a/.git-blame-ignore-revs b/.git-blame-ignore-revs
index 3418dc8b..abbe1289 100644
--- a/.git-blame-ignore-revs
+++ b/.git-blame-ignore-revs
@@ -15,3 +15,6 @@ d12fb4427a1ccff4660b6c559b858adfe4eebaf0
# Scala Steward: Reformat with scalafmt 3.8.6
d9d324b81fbfb13ceda5c6317c5ece84f6260443
+
+# Scala Steward: Reformat with scalafmt 3.9.10
+505a5761842906fff940554785dc94d98c89ad04
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@pekko.apache.org
For additional commands, e-mail: commits-help@pekko.apache.org
(pekko-connectors-kafka) 01/03: Update scalafmt-core to 3.9.10
Posted by gi...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
github-bot pushed a commit to branch update/scalafmt-core-3.9.10
in repository https://gitbox.apache.org/repos/asf/pekko-connectors-kafka.git
commit cab30c9e9e5a0a895b85ce5aa9918ffae8e3f576
Author: scala-steward-asf[bot] <14...@users.noreply.github.com>
AuthorDate: Wed Dec 3 13:58:06 2025 +0000
Update scalafmt-core to 3.9.10
---
.scalafmt.conf | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/.scalafmt.conf b/.scalafmt.conf
index 60f647d4..97477193 100644
--- a/.scalafmt.conf
+++ b/.scalafmt.conf
@@ -1,4 +1,4 @@
-version = 3.9.3
+version = 3.9.10
runner.dialect = scala213
project.git = true
style = defaultWithAlign
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@pekko.apache.org
For additional commands, e-mail: commits-help@pekko.apache.org
(pekko-connectors-kafka) 02/03: Reformat with scalafmt 3.9.10
Posted by gi...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
github-bot pushed a commit to branch update/scalafmt-core-3.9.10
in repository https://gitbox.apache.org/repos/asf/pekko-connectors-kafka.git
commit 505a5761842906fff940554785dc94d98c89ad04
Author: scala-steward-asf[bot] <14...@users.noreply.github.com>
AuthorDate: Wed Dec 3 13:58:14 2025 +0000
Reformat with scalafmt 3.9.10
Executed command: scalafmt --non-interactive
---
.../scala/org/apache/pekko/kafka/benchmarks/InflightMetrics.scala | 2 +-
core/src/main/scala/org/apache/pekko/kafka/CommitterSettings.scala | 2 +-
.../scala/org/apache/pekko/kafka/internal/DefaultProducerStage.scala | 2 +-
.../main/scala/org/apache/pekko/kafka/internal/DeferredProducer.scala | 2 +-
.../scala/org/apache/pekko/kafka/internal/KafkaConsumerActor.scala | 4 ++--
.../main/scala/org/apache/pekko/kafka/internal/MessageBuilder.scala | 2 +-
tests/src/test/scala/docs/scaladsl/proto/Order.scala | 2 +-
.../test/scala/org/apache/pekko/kafka/scaladsl/IntegrationSpec.scala | 4 ++--
.../test/scala/org/apache/pekko/kafka/tests/CapturingAppender.scala | 2 +-
tests/src/test/scala/org/apache/pekko/kafka/tests/LogbackUtil.scala | 4 ++--
10 files changed, 13 insertions(+), 13 deletions(-)
diff --git a/benchmarks/src/main/scala/org/apache/pekko/kafka/benchmarks/InflightMetrics.scala b/benchmarks/src/main/scala/org/apache/pekko/kafka/benchmarks/InflightMetrics.scala
index 3d5e5f98..0ff50627 100644
--- a/benchmarks/src/main/scala/org/apache/pekko/kafka/benchmarks/InflightMetrics.scala
+++ b/benchmarks/src/main/scala/org/apache/pekko/kafka/benchmarks/InflightMetrics.scala
@@ -263,7 +263,7 @@ private[benchmarks] object InflightMetrics {
def reset(measurements: List[Measurement], registry: MetricRegistry): List[Metric] = measurements.map {
case measurement @ Measurement(_, _, CounterMetricType, _) => BaseCounter(measurement, measurement)
- case measurement @ Measurement(_, _, GaugeMetricType, _) =>
+ case measurement @ Measurement(_, _, GaugeMetricType, _) =>
HistogramGauge(measurement, registry.histogram(measurement.name))
}
diff --git a/core/src/main/scala/org/apache/pekko/kafka/CommitterSettings.scala b/core/src/main/scala/org/apache/pekko/kafka/CommitterSettings.scala
index 08edde4d..9ba19bd8 100644
--- a/core/src/main/scala/org/apache/pekko/kafka/CommitterSettings.scala
+++ b/core/src/main/scala/org/apache/pekko/kafka/CommitterSettings.scala
@@ -101,7 +101,7 @@ object CommitWhen {
def valueOf(s: String): CommitWhen = s match {
case "OffsetFirstObserved" => OffsetFirstObserved
case "NextOffsetObserved" => NextOffsetObserved
- case other =>
+ case other =>
throw new IllegalArgumentException(
s"allowed values are: OffsetFirstObserved, NextOffsetObserved. Received: $other")
}
diff --git a/core/src/main/scala/org/apache/pekko/kafka/internal/DefaultProducerStage.scala b/core/src/main/scala/org/apache/pekko/kafka/internal/DefaultProducerStage.scala
index ac1e1895..38912d69 100644
--- a/core/src/main/scala/org/apache/pekko/kafka/internal/DefaultProducerStage.scala
+++ b/core/src/main/scala/org/apache/pekko/kafka/internal/DefaultProducerStage.scala
@@ -190,7 +190,7 @@ private class DefaultProducerStageLogic[K, V, P, IN <: Envelope[K, V, P], OUT <:
} else
decider(exception) match {
case Supervision.Stop => closeAndFailStageCb.invoke(exception)
- case _ =>
+ case _ =>
promise.failure(exception)
confirmAndCheckForCompletionCB.invoke(())
}
diff --git a/core/src/main/scala/org/apache/pekko/kafka/internal/DeferredProducer.scala b/core/src/main/scala/org/apache/pekko/kafka/internal/DeferredProducer.scala
index 746690f8..6e44d72d 100644
--- a/core/src/main/scala/org/apache/pekko/kafka/internal/DeferredProducer.scala
+++ b/core/src/main/scala/org/apache/pekko/kafka/internal/DeferredProducer.scala
@@ -79,7 +79,7 @@ private[kafka] trait DeferredProducer[K, V] {
producerFuture.value match {
case Some(Success(p)) => assignProducer(p)
case Some(Failure(e)) => failStage(e)
- case None =>
+ case None =>
val assign = getAsyncCallback(assignProducer)
producerFuture
.transform(
diff --git a/core/src/main/scala/org/apache/pekko/kafka/internal/KafkaConsumerActor.scala b/core/src/main/scala/org/apache/pekko/kafka/internal/KafkaConsumerActor.scala
index 848f5b36..fa1356a5 100644
--- a/core/src/main/scala/org/apache/pekko/kafka/internal/KafkaConsumerActor.scala
+++ b/core/src/main/scala/org/apache/pekko/kafka/internal/KafkaConsumerActor.scala
@@ -389,7 +389,7 @@ import scala.util.control.NonFatal
def stopping: Receive = LoggingReceive.withLabel("stopping") {
case p: Poll[_, _] =>
receivePoll(p)
- case _: StopLike =>
+ case _: StopLike =>
case Terminated(ref) =>
stageActorsMap = stageActorsMap.filterNot(_._2 == ref)
case _ @(_: Commit | _: RequestMessages) =>
@@ -403,7 +403,7 @@ import scala.util.control.NonFatal
log.debug("Starting {}", self)
val updateSettings: Future[ConsumerSettings[K, V]] = _settings.enriched
updateSettings.value match {
- case Some(Success(s)) => applySettings(s)
+ case Some(Success(s)) => applySettings(s)
case Some(scala.util.Failure(e)) =>
owner.foreach(_ ! Failure(e))
throw e
diff --git a/core/src/main/scala/org/apache/pekko/kafka/internal/MessageBuilder.scala b/core/src/main/scala/org/apache/pekko/kafka/internal/MessageBuilder.scala
index 4ca02f29..f985faac 100644
--- a/core/src/main/scala/org/apache/pekko/kafka/internal/MessageBuilder.scala
+++ b/core/src/main/scala/org/apache/pekko/kafka/internal/MessageBuilder.scala
@@ -192,7 +192,7 @@ private[kafka] final class CommittableOffsetBatchImpl(
val newCommitter = newOffset match {
case c: CommittableOffsetImpl => c.committer
- case _ =>
+ case _ =>
throw new IllegalArgumentException(
s"Unknown CommittableOffset, got [${newOffset.getClass.getName}], " +
s"expected [${classOf[CommittableOffsetImpl].getName}]")
diff --git a/tests/src/test/scala/docs/scaladsl/proto/Order.scala b/tests/src/test/scala/docs/scaladsl/proto/Order.scala
index a18627b5..0c897461 100644
--- a/tests/src/test/scala/docs/scaladsl/proto/Order.scala
+++ b/tests/src/test/scala/docs/scaladsl/proto/Order.scala
@@ -89,7 +89,7 @@ object Order extends scalapb.GeneratedMessageCompanion[docs.scaladsl.proto.Order
while (!_done__) {
val _tag__ = _input__.readTag()
_tag__ match {
- case 0 => _done__ = true
+ case 0 => _done__ = true
case 10 =>
__id = _input__.readStringRequireUtf8()
case tag =>
diff --git a/tests/src/test/scala/org/apache/pekko/kafka/scaladsl/IntegrationSpec.scala b/tests/src/test/scala/org/apache/pekko/kafka/scaladsl/IntegrationSpec.scala
index d8b20fae..1058face 100644
--- a/tests/src/test/scala/org/apache/pekko/kafka/scaladsl/IntegrationSpec.scala
+++ b/tests/src/test/scala/org/apache/pekko/kafka/scaladsl/IntegrationSpec.scala
@@ -126,8 +126,8 @@ class IntegrationSpec extends SpecBase with TestcontainersKafkaLike with Inside
val Partitions1 = Set(allTps(0), allTps(1))
val Partitions2 = Set(allTps(2), allTps(3))
(assigned1.topicPartitions, assigned2.topicPartitions) match {
- case (Partitions1, Partitions2) =>
- case (Partitions2, Partitions1) =>
+ case (Partitions1, Partitions2) =>
+ case (Partitions2, Partitions1) =>
case (receivePartitions1, receivedPartitions2) =>
fail(
s"The `TopicPartitionsAssigned` contained different topic partitions than expected:\nrebalanceActor1: $receivePartitions1\nrebalanceActor2: $receivedPartitions2")
diff --git a/tests/src/test/scala/org/apache/pekko/kafka/tests/CapturingAppender.scala b/tests/src/test/scala/org/apache/pekko/kafka/tests/CapturingAppender.scala
index ffa4a2b3..d6817aaa 100644
--- a/tests/src/test/scala/org/apache/pekko/kafka/tests/CapturingAppender.scala
+++ b/tests/src/test/scala/org/apache/pekko/kafka/tests/CapturingAppender.scala
@@ -36,7 +36,7 @@ import ch.qos.logback.core.AppenderBase
throw new IllegalStateException(
s"$CapturingAppenderName not defined for [${loggerNameOrRoot(loggerName)}] in logback-test.xml")
case appender: CapturingAppender => appender
- case other =>
+ case other =>
throw new IllegalStateException(s"Unexpected $CapturingAppender: $other")
}
}
diff --git a/tests/src/test/scala/org/apache/pekko/kafka/tests/LogbackUtil.scala b/tests/src/test/scala/org/apache/pekko/kafka/tests/LogbackUtil.scala
index 1b181541..40eed960 100644
--- a/tests/src/test/scala/org/apache/pekko/kafka/tests/LogbackUtil.scala
+++ b/tests/src/test/scala/org/apache/pekko/kafka/tests/LogbackUtil.scala
@@ -30,7 +30,7 @@ import org.slf4j.LoggerFactory
def getLogbackLogger(loggerName: String): ch.qos.logback.classic.Logger = {
LoggerFactory.getLogger(loggerNameOrRoot(loggerName)) match {
case logger: ch.qos.logback.classic.Logger => logger
- case null =>
+ case null =>
throw new IllegalArgumentException(s"Couldn't find logger for [$loggerName].")
case other =>
throw new IllegalArgumentException(
@@ -45,7 +45,7 @@ import org.slf4j.LoggerFactory
case ch.qos.logback.classic.Level.INFO_INT => Level.INFO
case ch.qos.logback.classic.Level.WARN_INT => Level.WARN
case ch.qos.logback.classic.Level.ERROR_INT => Level.ERROR
- case _ =>
+ case _ =>
throw new IllegalArgumentException("Level " + level.levelStr + ", " + level.levelInt + " is unknown.")
}
}
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@pekko.apache.org
For additional commands, e-mail: commits-help@pekko.apache.org