private static ConfigDef createSinkConfigDef()

in timebase-kafka-connector/src/main/java/deltix/kafka/connect/TBConnectorConfig.java [66:81]
16 lines of code
1 McCabe index (conditional complexity)

    private static ConfigDef createSinkConfigDef() {
        ConfigDef def = new ConfigDef();
        addTBConnectionOptions(def);
        def.define(TB_MESSAGE_ID_PROP, ConfigDef.Type.STRING, null, ConfigDef.Importance.LOW, "TimeBase field for storing Kafka records Offsets");
        def.define(TB_MESSAGE_KEY_PROP, ConfigDef.Type.STRING, null, ConfigDef.Importance.LOW, "TimeBase field for storing Kafka records Keys");
        def.define(TB_MESSAGE_TOMBSTONE_PROP, ConfigDef.Type.STRING, null, ConfigDef.Importance.LOW, "TimeBase tombstone message marker field");
        def.define(INSTRUMENT_FIELD_PROP, ConfigDef.Type.STRING, null, ConfigDef.Importance.LOW, "Topic field to store as TimeBase message Instrument Type");
        def.define(SYMBOL_FIELD_PROP, ConfigDef.Type.STRING, null, ConfigDef.Importance.LOW, "Topic field to store as TimeBase message Symbol");
        def.define(TIME_FIELD_PROP, ConfigDef.Type.STRING, null, ConfigDef.Importance.LOW, "Topic field to store as TimeBase message Time");
        def.define(INCLUDE_PROP, ConfigDef.Type.STRING, null, ConfigDef.Importance.LOW, "Topic fields that should be included in TimeBase messages");
        def.define(EXCLUDE_PROP, ConfigDef.Type.STRING, null, ConfigDef.Importance.LOW, "Topic fields that should be excluded from TimeBase messages");
        def.define(TIMESTAMP_FIELDS_PROP, ConfigDef.Type.STRING, null, ConfigDef.Importance.LOW, "Topic fields that should be interpreted as timestamps in ms");
        def.define(FLATTEN_FIELDS_PROP, ConfigDef.Type.LIST, null, ConfigDef.Importance.LOW, "Flatten top level fields with sub-structures");
        def.define(RENAME_FIELDS_PROP, ConfigDef.Type.STRING, null, ConfigDef.Importance.LOW, "Rename fields according to specified aliases");
        return def;
    }