private static ConfigDef createSourceConfigDef()

in timebase-kafka-connector/src/main/java/deltix/kafka/connect/TBConnectorConfig.java [49:64]

• 15 lines of code
• 1 McCabe index (conditional complexity)

    private static ConfigDef createSourceConfigDef() {
        ConfigDef def = new ConfigDef();
        addTBConnectionOptions(def);
        def.define(TB_MESSAGE_ID_PROP, ConfigDef.Type.STRING, null, ConfigDef.Importance.LOW, "TimeBase field containing Message ID");
        def.define(TB_MESSAGE_TYPE_PROP, ConfigDef.Type.STRING, null, ConfigDef.Importance.LOW, "Type of TimeBase messages to include");

        def.define(TOPIC_PROP, ConfigDef.Type.STRING, ConfigDef.Importance.HIGH, "Kafka Topic for storing TimeBase messages");
        def.define(INSTRUMENT_FIELD_PROP, ConfigDef.Type.STRING, null, ConfigDef.Importance.LOW, "Topic field to store message Instrument Type");
        def.define(SYMBOL_FIELD_PROP, ConfigDef.Type.STRING, null, ConfigDef.Importance.LOW, "Topic field to store message Symbol");
        def.define(TIME_FIELD_PROP, ConfigDef.Type.STRING, null, ConfigDef.Importance.LOW, "Topic field to store message Time");
        def.define(INCLUDE_PROP, ConfigDef.Type.STRING, null, ConfigDef.Importance.LOW, "TimeBase fields that should be included");
        def.define(EXCLUDE_PROP, ConfigDef.Type.STRING, null, ConfigDef.Importance.LOW, "TimeBase fields that should be excluded");
        def.define(RENAME_FIELDS_PROP, ConfigDef.Type.STRING, null, ConfigDef.Importance.LOW, "Rename fields according to specified aliases");
        def.define(KEY_FIELDS_PROP, ConfigDef.Type.LIST, null, ConfigDef.Importance.LOW, "TimeBase fields to use as record key");
        return def;
    }