This is an automated email from the ASF dual-hosted git repository. Philippus pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/pekko-connectors-kafka.git
commit e8d6e58eb07efa93ca8b956df22e4b27eb214b32 Author: Philippus <[email protected]> AuthorDate: Tue May 5 23:15:59 2026 +0200 Reformat with sbt-java-formatter 0.12.0 --- java-tests/src/test/java/docs/javadsl/TestkitSamplesTest.java | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/java-tests/src/test/java/docs/javadsl/TestkitSamplesTest.java b/java-tests/src/test/java/docs/javadsl/TestkitSamplesTest.java index 56f7d226..79c71e0a 100644 --- a/java-tests/src/test/java/docs/javadsl/TestkitSamplesTest.java +++ b/java-tests/src/test/java/docs/javadsl/TestkitSamplesTest.java @@ -99,7 +99,10 @@ public class TestkitSamplesTest { create() .map( msg -> { - if (msg instanceof ProducerMessage.Message<String, String, ConsumerMessage.CommittableOffset> pmsg) { + if (msg + instanceof + ProducerMessage.Message<String, String, ConsumerMessage.CommittableOffset> + pmsg) { return ProducerResultFactory.result(pmsg); } else throw new RuntimeException("unexpected element: " + msg); }); --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
