remove not used outgoing annotation and related code

quarkusio · Sep 25, 2023 · 6401a2a · 6401a2a
1 parent 12690df
commit 6401a2a
Showing 1 changed file with 0 additions and 2 deletions.
diff --git 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<Void> process(KafkaRecordBatch<String, Order> orders) {
         System.out.println("Order received " + orders.getPayload().size());
         return orders.ack();
@@ -2091,7 +2090,6 @@ class BaristaTest {
     @Test
     void testProcessOrder() {
         InMemorySource<IncomingKafkaRecordBatch<String, Order>> ordersIn = connector.source("orders");
-        InMemorySink<Beverage> beveragesOut = connector.sink("beverages");
         var committed = new AtomicBoolean(false);  // <1>
         var commitHandler = new KafkaCommitHandler() {
             @Override