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/pekko-connectors-kafka.git
commit 183d00ee1b87ab43859ced003ec8c6cb84f31879 Author: Scala Steward <[email protected]> AuthorDate: Wed Jan 28 16:16:19 2026 +0000 Reformat with scalafmt 3.10.5 Executed command: scalafmt --non-interactive --- .../pekko/kafka/benchmarks/KafkaTransactionFixtureGen.scala | 5 ++++- .../benchmarks/PekkoConnectorsCommittableSinkFixtures.scala | 5 ++++- .../kafka/benchmarks/ReactiveKafkaTransactionFixtures.scala | 5 ++++- .../org/apache/pekko/kafka/internal/KafkaConsumerActor.scala | 9 ++++++++- .../scala/org/apache/pekko/kafka/internal/MessageBuilder.scala | 6 +++++- .../scala/org/apache/pekko/kafka/scaladsl/Transactional.scala | 5 ++++- project/ParadoxSettings.scala | 6 +++++- .../apache/pekko/kafka/testkit/internal/KafkaTestKitChecks.scala | 5 ++++- 8 files changed, 38 insertions(+), 8 deletions(-) diff --git a/benchmarks/src/main/scala/org/apache/pekko/kafka/benchmarks/KafkaTransactionFixtureGen.scala b/benchmarks/src/main/scala/org/apache/pekko/kafka/benchmarks/KafkaTransactionFixtureGen.scala index 51d439bf..52451061 100644 --- a/benchmarks/src/main/scala/org/apache/pekko/kafka/benchmarks/KafkaTransactionFixtureGen.scala +++ b/benchmarks/src/main/scala/org/apache/pekko/kafka/benchmarks/KafkaTransactionFixtureGen.scala @@ -22,7 +22,10 @@ import org.apache.kafka.clients.consumer.{ ConsumerConfig, KafkaConsumer } import org.apache.kafka.clients.producer.{ KafkaProducer, ProducerConfig } import org.apache.kafka.common.IsolationLevel import org.apache.kafka.common.serialization.{ - ByteArrayDeserializer, ByteArraySerializer, StringDeserializer, StringSerializer + ByteArrayDeserializer, + ByteArraySerializer, + StringDeserializer, + StringSerializer } import scala.jdk.CollectionConverters._ diff --git a/benchmarks/src/main/scala/org/apache/pekko/kafka/benchmarks/PekkoConnectorsCommittableSinkFixtures.scala b/benchmarks/src/main/scala/org/apache/pekko/kafka/benchmarks/PekkoConnectorsCommittableSinkFixtures.scala index 35dfb8bc..46074109 100644 --- a/benchmarks/src/main/scala/org/apache/pekko/kafka/benchmarks/PekkoConnectorsCommittableSinkFixtures.scala +++ b/benchmarks/src/main/scala/org/apache/pekko/kafka/benchmarks/PekkoConnectorsCommittableSinkFixtures.scala @@ -30,7 +30,10 @@ import com.typesafe.scalalogging.LazyLogging import org.apache.kafka.clients.consumer.ConsumerConfig import org.apache.kafka.clients.producer.ProducerRecord import org.apache.kafka.common.serialization.{ - ByteArrayDeserializer, ByteArraySerializer, StringDeserializer, StringSerializer + ByteArrayDeserializer, + ByteArraySerializer, + StringDeserializer, + StringSerializer } import scala.concurrent.duration._ diff --git a/benchmarks/src/main/scala/org/apache/pekko/kafka/benchmarks/ReactiveKafkaTransactionFixtures.scala b/benchmarks/src/main/scala/org/apache/pekko/kafka/benchmarks/ReactiveKafkaTransactionFixtures.scala index 3cdf2301..4b5be6b6 100644 --- a/benchmarks/src/main/scala/org/apache/pekko/kafka/benchmarks/ReactiveKafkaTransactionFixtures.scala +++ b/benchmarks/src/main/scala/org/apache/pekko/kafka/benchmarks/ReactiveKafkaTransactionFixtures.scala @@ -26,7 +26,10 @@ import pekko.kafka.{ ConsumerMessage, ConsumerSettings, ProducerSettings, Subscr import pekko.stream.scaladsl.{ Flow, Source } import org.apache.kafka.clients.consumer.ConsumerConfig import org.apache.kafka.common.serialization.{ - ByteArrayDeserializer, ByteArraySerializer, StringDeserializer, StringSerializer + ByteArrayDeserializer, + ByteArraySerializer, + StringDeserializer, + StringSerializer } import scala.concurrent.duration.FiniteDuration 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 b15f6b3d..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 @@ -21,7 +21,14 @@ import org.apache.pekko import pekko.Done import pekko.actor.Status.Failure import pekko.actor.{ - Actor, ActorRef, DeadLetterSuppression, NoSerializationVerificationNeeded, Stash, Status, Terminated, Timers + Actor, + ActorRef, + DeadLetterSuppression, + NoSerializationVerificationNeeded, + Stash, + Status, + Terminated, + Timers } import pekko.annotation.InternalApi import pekko.event.LoggingReceive 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 89273b89..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 @@ -21,7 +21,11 @@ import pekko.Done import pekko.annotation.InternalApi import pekko.kafka.ConsumerMessage import pekko.kafka.ConsumerMessage.{ - CommittableMessage, CommittableOffsetMetadata, GroupTopicPartition, TransactionalMessage, _ + CommittableMessage, + CommittableOffsetMetadata, + GroupTopicPartition, + TransactionalMessage, + _ } import org.apache.kafka.clients.consumer.{ ConsumerRecord, OffsetAndMetadata } import org.apache.kafka.common.TopicPartition diff --git a/core/src/main/scala/org/apache/pekko/kafka/scaladsl/Transactional.scala b/core/src/main/scala/org/apache/pekko/kafka/scaladsl/Transactional.scala index 752ee6a2..22039eee 100644 --- a/core/src/main/scala/org/apache/pekko/kafka/scaladsl/Transactional.scala +++ b/core/src/main/scala/org/apache/pekko/kafka/scaladsl/Transactional.scala @@ -19,7 +19,10 @@ import pekko.annotation.{ ApiMayChange, InternalApi } import pekko.kafka.ConsumerMessage.{ PartitionOffset, TransactionalMessage } import pekko.kafka.ProducerMessage._ import pekko.kafka.internal.{ - TransactionalProducerStage, TransactionalSource, TransactionalSourceWithOffsetContext, TransactionalSubSource + TransactionalProducerStage, + TransactionalSource, + TransactionalSourceWithOffsetContext, + TransactionalSubSource } import pekko.kafka.scaladsl.Consumer.Control import pekko.kafka.{ AutoSubscription, ConsumerMessage, ConsumerSettings, ProducerSettings, Subscription } diff --git a/project/ParadoxSettings.scala b/project/ParadoxSettings.scala index ee75aa33..d5c455f2 100644 --- a/project/ParadoxSettings.scala +++ b/project/ParadoxSettings.scala @@ -10,7 +10,11 @@ import Versions._ import com.lightbend.paradox.apidoc.ApidocPlugin.autoImport.apidocRootPackage import com.lightbend.paradox.sbt.ParadoxPlugin.autoImport.{ - paradox, paradoxGroups, paradoxMarkdownToHtml, paradoxProperties, paradoxRoots + paradox, + paradoxGroups, + paradoxMarkdownToHtml, + paradoxProperties, + paradoxRoots } import org.apache.pekko.PekkoParadoxPlugin.autoImport._ import sbt._ diff --git a/testkit/src/main/scala/org/apache/pekko/kafka/testkit/internal/KafkaTestKitChecks.scala b/testkit/src/main/scala/org/apache/pekko/kafka/testkit/internal/KafkaTestKitChecks.scala index f34e9aaf..93478018 100644 --- a/testkit/src/main/scala/org/apache/pekko/kafka/testkit/internal/KafkaTestKitChecks.scala +++ b/testkit/src/main/scala/org/apache/pekko/kafka/testkit/internal/KafkaTestKitChecks.scala @@ -18,7 +18,10 @@ import java.util.Collections import java.util.concurrent.TimeUnit import org.apache.kafka.clients.admin.{ - Admin, ConsumerGroupDescription, DescribeClusterResult, DescribeConsumerGroupsOptions + Admin, + ConsumerGroupDescription, + DescribeClusterResult, + DescribeConsumerGroupsOptions } import org.slf4j.Logger --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
