Skip to content

Commit

Permalink
format java samples
Browse files Browse the repository at this point in the history
  • Loading branch information
johanandren committed Apr 3, 2024
1 parent 918b0c7 commit a879aa7
Showing 1 changed file with 1 addition and 3 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -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);

// ...
Expand Down

0 comments on commit a879aa7

Please sign in to comment.