diff --git a/tests/src/test/java/docs/javadsl/TransactionsExampleTest.java b/tests/src/test/java/docs/javadsl/TransactionsExampleTest.java index a55bff7a3..88b4d2887 100644 --- a/tests/src/test/java/docs/javadsl/TransactionsExampleTest.java +++ b/tests/src/test/java/docs/javadsl/TransactionsExampleTest.java @@ -75,9 +75,7 @@ public void sourceSink() throws Exception { ProducerMessage.single( new ProducerRecord<>(targetTopic, msg.record().key(), msg.record().value()), msg.partitionOffset())) - .toMat( - Transactional.sink(producerSettings), - Consumer::createDrainingControl) + .toMat(Transactional.sink(producerSettings), Consumer::createDrainingControl) .run(system); // ...