diff --git a/docs/src/main/asciidoc/kafka.adoc b/docs/src/main/asciidoc/kafka.adoc index acffcfa401ca1..25e142198b021 100644 --- a/docs/src/main/asciidoc/kafka.adoc +++ b/docs/src/main/asciidoc/kafka.adoc @@ -2067,7 +2067,6 @@ For instance: public class BeverageProcessor { @Incoming("orders") - @Outgoing("beverages") CompletionStage process(KafkaRecordBatch orders) { System.out.println("Order received " + orders.getPayload().size()); return orders.ack(); @@ -2091,7 +2090,6 @@ class BaristaTest { @Test void testProcessOrder() { InMemorySource> ordersIn = connector.source("orders"); - InMemorySink beveragesOut = connector.sink("beverages"); var committed = new AtomicBoolean(false); // <1> var commitHandler = new KafkaCommitHandler() { @Override