public void start()

in timebase-kafka-connector/src/main/java/deltix/kafka/connect/TBSinkTask.java [40:66]

• 13 lines of code
• 4 McCabe index (conditional complexity)

    public void start(Map<String, String> props) {
        config = new TBConnectorConfig(SINK_CONFIG_DEF, props);

        offsetField = config.getTBMessageIDField();

        timebase = TickDBFactory.createFromUrl(config.getTBUrl(), config.getTBUser(), config.getTBPassword());
        timebase.open(false);
        msgStream = timebase.getStream(config.getTBStream());

        String topic = props.get(TOPICS_CONFIG);
        if (topic == null || topic.split(",").length != 1) {
            throw new IllegalArgumentException("Expecting a single topic instead of " + topic);
        }

        if (msgStream != null)
            lastMessageTimestamp = getLastMessageTimestamp();

//        if (msgStream != null) {
//            //Struct record = getLastRecord();
//            if (offsetField != null && record != null) {
//                //Long offset = record.getInt64(offsetField);
//                //TopicPartition partition = new TopicPartition(topic, 0);
//                //LOG.info("Starting at partition " + partition + " offset: " + offset);
//                //context.offset(partition, offset);
//            }
//        }
    }