in timebase-kafka-connector/src/main/java/deltix/kafka/connect/TBSinkTask.java [124:137]
private void send(RawMessage message) {
if (tbLoader == null) {
if (msgStream == null) {
String tbStream = config.getTBStream();
StreamOptions options = new StreamOptions(StreamScope.DURABLE, tbStream, "Created by TBSinkConnector", StreamOptions.MAX_DISTRIBUTION);
options.setFixedType(message.type);
msgStream = timebase.createStream(tbStream, options);
}
LoadingOptions options = new LoadingOptions(true);
options.writeMode = LoadingOptions.WriteMode.APPEND;
tbLoader = msgStream.createLoader(options);
}
tbLoader.send(message);
}