Use better name for field name config (#3)

Co-authored-by: Schulte, Johannes <johannes.schulte@eventim.de>
baunz · May 5, 2021 · ed07eab · ed07eab
1 parent 24480c3
commit ed07eab
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/src/main/java/com/github/baunz/kafka/connect/storage/StructConverterConfig.java b/src/main/java/com/github/baunz/kafka/connect/storage/StructConverterConfig.java
@@ -29,7 +29,7 @@
  */
 public class StructConverterConfig extends ConverterConfig {
 
-    public static final String FIELD_NAME_CONFIG = "converter.fieldname";
+    public static final String FIELD_NAME_CONFIG = "fieldname";
     public static final String FIELD_NAME_DEFAULT = "value";
     private static final String FIELD_NAME_DOC = "The name of the field that contains the string value in the resulting struct.";
     private static final String FIELD_NAME_DISPLAY = "Field name to use for the struct";

diff --git a/src/test/java/com/github/baunz/kafka/connect/storage/StructConverterTest.java b/src/test/java/com/github/baunz/kafka/connect/storage/StructConverterTest.java
@@ -22,7 +22,7 @@ class StructConverterTest {
 
     @BeforeAll
     void beforeAll() {
-        converter.configure(Collections.singletonMap("converter.fieldname", CUSTOM_FIELD_NAME), true);
+        converter.configure(Collections.singletonMap("fieldname", CUSTOM_FIELD_NAME), true);
     }
 
     private Struct assertSchemaAndStruct(SchemaAndValue schemaAndValue) {