From 6401a2aeab25f2ce33841d01353854b3e3c982c0 Mon Sep 17 00:00:00 2001
From: Will Li <cuichen.li@appdynamics.com>
Date: Mon, 25 Sep 2023 14:30:07 +0800
Subject: [PATCH] remove not used outgoing annotation and related code

---
 docs/src/main/asciidoc/kafka.adoc | 2 --
 1 file changed, 2 deletions(-)

diff --git a/docs/src/main/asciidoc/kafka.adoc b/docs/src/main/asciidoc/kafka.adoc
index acffcfa401ca13..25e142198b0218 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<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