RB-476 - Take a branch and rename the classes (#980)

lensesio · Sep 6, 2023 · 5d89d2f · 5d89d2f
1 parent 8499fd9
commit 5d89d2f
Show file tree

Hide file tree

Showing 17 changed files with 85 additions and 85 deletions.
diff --git a/kafka-connect-aws-s3/README-sink.md b/kafka-connect-aws-s3/README-sink.md
@@ -7,7 +7,7 @@ Before reading this document it is recommended to be familiar with the [general
 An example configuration is provided:
 
     name=S3SinkConnectorParquet # this can be anything
-    connector.class=io.lenses.streamreactor.connect.aws.s3.sink.S3SinkConnector
+    connector.class=io.lenses.streamreactor.connect.aws.s3.sink.S3SinkConnectorDeprecated
     topics=$TOPIC_NAME
     tasks.max=1
     connect.s3.kcql=insert into $BUCKET_NAME:$PREFIX_NAME select * from $TOPIC_NAME STOREAS `parquet` WITH_FLUSH_COUNT = 5000 

diff --git a/kafka-connect-aws-s3/README-source.md b/kafka-connect-aws-s3/README-source.md
@@ -12,7 +12,7 @@ The source files may have been written by the Lenses.io S3 Sink or other produce
 An example configuration is provided:
 
     name=S3SourceConnectorParquet # this can be anything
-    connector.class=io.lenses.streamreactor.connect.aws.s3.source.S3SourceConnector
+    connector.class=io.lenses.streamreactor.connect.aws.s3.source.S3SourceConnectorDeprecated
     tasks.max=1
     connect.s3.kcql=insert into $TOPIC_NAME select * from $BUCKET_NAME:$PREFIX_NAME STOREAS `parquet`
     connect.s3.aws.secret.key=SECRET_KEY

diff --git a/kafka-connect-aws-s3/src/fun/scala/io/lenses/streamreactor/connect/Configuration.scala b/kafka-connect-aws-s3/src/fun/scala/io/lenses/streamreactor/connect/Configuration.scala
@@ -19,7 +19,7 @@ object Configuration {
     ConnectorConfiguration(
       "connector" + randomTestId,
       Map(
-        "connector.class"            -> ConfigValue("io.lenses.streamreactor.connect.aws.s3.sink.S3SinkConnector"),
+        "connector.class"            -> ConfigValue("io.lenses.streamreactor.connect.aws.s3.sink.S3SinkConnectorDeprecated"),
         "tasks.max"                  -> ConfigValue(1),
         "topics"                     -> ConfigValue(topicName),
         "connect.s3.aws.access.key"  -> ConfigValue(auth.identity),

diff --git a/...src/it/scala/io/lenses/streamreactor/connect/aws/s3/sink/S3SinkTaskAvroEnvelopeTest.scala b/...src/it/scala/io/lenses/streamreactor/connect/aws/s3/sink/S3SinkTaskAvroEnvelopeTest.scala
@@ -98,7 +98,7 @@ class S3SinkTaskAvroEnvelopeTest
 
   "S3SinkTask" should "write to avro format" in {
 
-    val task = new S3SinkTask()
+    val task = new S3SinkTaskDeprecated()
 
     val props = DefaultProps
       .combine(
@@ -232,7 +232,7 @@ class S3SinkTaskAvroEnvelopeTest
 
   "S3SinkTask" should "write to avro format when input is java Map" in {
 
-    val task = new S3SinkTask()
+    val task = new S3SinkTaskDeprecated()
 
     val props = DefaultProps
       .combine(