Skip to content

Commit ea93999

Browse files
committed
fix
1 parent fbe31b6 commit ea93999

File tree

1 file changed

+4
-6
lines changed
  • src/main/java/com/databend/kafka/connect/sink/records

1 file changed

+4
-6
lines changed

src/main/java/com/databend/kafka/connect/sink/records/Record.java

Lines changed: 4 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -6,19 +6,17 @@
66
import org.apache.kafka.connect.data.Struct;
77
import org.apache.kafka.connect.errors.DataException;
88
import org.apache.kafka.connect.sink.SinkRecord;
9-
import org.slf4j.Logger;
10-
import org.slf4j.LoggerFactory;
119

1210
import java.util.List;
1311
import java.util.Map;
1412

1513
public class Record {
16-
private OffsetContainer recordOffsetContainer = null;
14+
private OffsetContainer recordOffsetContainer;
1715
private Object value;
18-
private Map<String, Data> jsonMap = null;
19-
private List<Field> fields = null;
16+
private Map<String, Data> jsonMap;
17+
private List<Field> fields;
2018
private SchemaType schemaType;
21-
private SinkRecord sinkRecord = null;
19+
private SinkRecord sinkRecord;
2220

2321
public Record(SchemaType schemaType, OffsetContainer recordOffsetContainer, List<Field> fields, Map<String, Data> jsonMap, SinkRecord sinkRecord) {
2422
this.recordOffsetContainer = recordOffsetContainer;

0 commit comments

Comments
 (0)