This is an automated email from the ASF dual-hosted git repository.
hepin 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 63f2ae0e Unwrap single string interpolation syntax
63f2ae0e is described below
commit 63f2ae0e62b86d3fe1957825e344ca38721d3732
Author: Matthew de Detrich <[email protected]>
AuthorDate: Sat May 27 11:59:35 2023 +0200
Unwrap single string interpolation syntax
---
.../it/scala/org/apache/pekko/kafka/PartitionedSourceFailoverSpec.scala | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git
a/tests/src/it/scala/org/apache/pekko/kafka/PartitionedSourceFailoverSpec.scala
b/tests/src/it/scala/org/apache/pekko/kafka/PartitionedSourceFailoverSpec.scala
index 75010572..a252f9db 100644
---
a/tests/src/it/scala/org/apache/pekko/kafka/PartitionedSourceFailoverSpec.scala
+++
b/tests/src/it/scala/org/apache/pekko/kafka/PartitionedSourceFailoverSpec.scala
@@ -72,7 +72,7 @@ class PartitionedSourceFailoverSpec
.groupBy(partitions, _._1)
.mapAsync(8) {
case (tp, source) =>
- log.info(s"Sub-source for ${tp}")
+ log.info(s"Sub-source for $tp")
source
.scan(0L)((c, _) => c + 1)
.via(IntegrationTests.logReceivedMessages(tp)(log))
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
