Remove schema registry support from core module

bakdata · Jul 26, 2024 · 9529938 · 9529938
1 parent cb4fd69
commit 9529938
Show file tree

Hide file tree

Showing 2 changed files with 0 additions and 12 deletions.
diff --git 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
@@ -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", ".*",