in timebase-kafka-connector/src/main/java/deltix/kafka/connect/TBSinkTask.java [40:66]
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);
// }
// }
}