From 95299380fb6373c65f5fed7ec598ecb47f2e3020 Mon Sep 17 00:00:00 2001
From: Philipp Schirmer <philipp.schirmer@bakdata.com>
Date: Fri, 26 Jul 2024 10:32:27 +0200
Subject: [PATCH] Remove schema registry support from core module

---
 README.md                                                 | 4 ----
 .../src/test/java/com/bakdata/kafka/CliTest.java          | 8 --------
 2 files changed, 12 deletions(-)

diff --git a/README.md b/README.md
index ea027e22..8367e700 100644
--- a/README.md
+++ b/README.md
@@ -109,8 +109,6 @@ The following configuration options are available:
 
 - `--brokers`: List of Kafka brokers (comma-separated) (**required**)
 
-- `--schema-registry-url`: The URL of the Schema Registry
-
 - `--kafka-config`: Kafka Streams configuration (`<String=String>[,<String=String>...]`)
 
 - `--input-topics`: List of input topics (comma-separated)
@@ -192,8 +190,6 @@ The following configuration options are available:
 
 - `--brokers`: List of Kafka brokers (comma-separated) (**required**)
 
-- `--schema-registry-url`: The URL of the Schema Registry
-
 - `--kafka-config`: Kafka producer configuration (`<String=String>[,<String=String>...]`)
 
 - `--output-topic`: The output topic
diff --git a/streams-bootstrap-cli/src/test/java/com/bakdata/kafka/CliTest.java b/streams-bootstrap-cli/src/test/java/com/bakdata/kafka/CliTest.java
index 88dad30a..114f5e42 100644
--- a/streams-bootstrap-cli/src/test/java/com/bakdata/kafka/CliTest.java
+++ b/streams-bootstrap-cli/src/test/java/com/bakdata/kafka/CliTest.java
@@ -78,7 +78,6 @@ public void run() {
             }
         }, new String[]{
                 "--brokers", "localhost:9092",
-                "--schema-registry-url", "http://localhost:8081",
                 "--input-topics", "input",
                 "--output-topic", "output",
         });
@@ -104,7 +103,6 @@ public SerdeConfig defaultSerializationConfig() {
             }
         }), new String[]{
                 "--brokers", "localhost:9092",
-                "--schema-registry-url", "http://localhost:8081",
                 "--input-topics", "input",
                 "--output-topic", "output",
         });
@@ -140,7 +138,6 @@ public void clean() {
             }
         }, new String[]{
                 "--brokers", "localhost:9092",
-                "--schema-registry-url", "http://localhost:8081",
                 "--input-topics", "input",
                 "--output-topic", "output",
                 "clean",
@@ -176,7 +173,6 @@ public void run() {
                 // do nothing
             }
         }, new String[]{
-                "--schema-registry-url", "http://localhost:8081",
                 "--input-topics", "input",
                 "--output-topic", "output",
         });
@@ -211,7 +207,6 @@ public SerdeConfig defaultSerializationConfig() {
 
             runApp(app,
                     "--brokers", kafkaCluster.getBrokerList(),
-                    "--schema-registry-url", "http://localhost:8081",
                     "--input-topics", input
             );
             kafkaCluster.send(SendKeyValues.to(input, List.of(new KeyValue<>("foo", "bar"))));
@@ -248,7 +243,6 @@ public SerdeConfig defaultSerializationConfig() {
 
             runApp(app,
                     "--brokers", kafkaCluster.getBrokerList(),
-                    "--schema-registry-url", "http://localhost:8081",
                     "--input-topics", input,
                     "--output-topic", output
             );
@@ -289,7 +283,6 @@ public SerdeConfig defaultSerializationConfig() {
             }
         }, new String[]{
                 "--brokers", "localhost:9092",
-                "--schema-registry-url", "http://localhost:8081",
                 "--input-topics", "input",
                 "--output-topic", "output",
                 "clean",
@@ -326,7 +319,6 @@ public void run() {
         }) {
             KafkaApplication.startApplicationWithoutExit(app, new String[]{
                     "--brokers", "brokers",
-                    "--schema-registry-url", "schema-registry",
                     "--input-topics", "input1,input2",
                     "--extra-input-topics", "role1=input3,role2=input4;input5",
                     "--input-pattern", ".*",