package org.sigma.debezium.converter;
import java.util.Properties;

import org.apache.kafka.connect.data.SchemaBuilder;

import io.debezium.spi.converter.CustomConverter;
import io.debezium.spi.converter.RelationalColumn;

public class Converter {
    public static class IsbnConverter implements CustomConverter<SchemaBuilder, RelationalColumn> {

        private SchemaBuilder isbnSchema;

        @Override
        public void converterFor(RelationalColumn column,
                ConverterRegistration<SchemaBuilder> registration) {
            System.out.println("=====> converterFor");
            if ("isbn".equals(column.typeName())) {
                registration.register(isbnSchema, x -> x.toString());
            }
        }

        @Override
        public void configure(Properties props) {
            // TODO Auto-generated method stub
            System.out.println("=====> configure");
            isbnSchema = SchemaBuilder.string().name(props.getProperty("schema.name"));
        }
    }
}