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 index 3c51433..a3823b0 100644 --- 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 index 9744268..e29c8ef 100644 --- 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) {