зеркало из
1
0
Форкнуть 0
This commit is contained in:
hasher 2020-07-15 16:58:25 +05:30
Родитель c701f4141a
Коммит 52ca6d06e0
2 изменённых файлов: 12 добавлений и 2 удалений

Просмотреть файл

@ -4,7 +4,12 @@ import com.microsoft.azure.kusto.kafka.connect.sink.format.RecordWriter;
import org.apache.kafka.connect.sink.SinkRecord;
import org.junit.Test;
import java.io.*;
import java.io.File;
import java.io.IOException;
import java.io.FileOutputStream;
import java.io.OutputStream;
import java.io.BufferedReader;
import java.io.FileReader;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;

Просмотреть файл

@ -5,7 +5,12 @@ import org.apache.kafka.connect.data.Schema;
import org.apache.kafka.connect.sink.SinkRecord;
import org.junit.Test;
import java.io.*;
import java.io.File;
import java.io.IOException;
import java.io.FileOutputStream;
import java.io.OutputStream;
import java.io.BufferedReader;
import java.io.FileReader;
import java.util.ArrayList;
import java.util.List;