File tree Expand file tree Collapse file tree 1 file changed +0
-4
lines changed
src/main/java/io/confluent/kafka/connect/datagen Expand file tree Collapse file tree 1 file changed +0
-4
lines changed Original file line number Diff line number Diff line change 22
22
import java .util .Arrays ;
23
23
import java .util .Collections ;
24
24
import java .util .HashMap ;
25
- import java .util .HashSet ;
26
25
import java .util .List ;
27
26
import java .util .Map ;
28
27
import java .util .Random ;
35
34
import java .util .concurrent .TimeoutException ;
36
35
import java .util .stream .Collectors ;
37
36
import org .apache .avro .generic .GenericRecord ;
38
- import org .apache .kafka .connect .data .Field ;
39
37
import org .apache .kafka .connect .data .Schema ;
40
38
import org .apache .kafka .connect .data .SchemaAndValue ;
41
- import org .apache .kafka .connect .data .SchemaBuilder ;
42
- import org .apache .kafka .connect .data .Struct ;
43
39
import org .apache .kafka .connect .errors .ConnectException ;
44
40
import org .apache .kafka .connect .header .ConnectHeaders ;
45
41
import org .apache .kafka .connect .source .SourceRecord ;
You can’t perform that action at this time.
0 commit comments