src/main/java/com/aliyun/odps/kafka/connect/converter/BinaryRecordConverter.java [45:55]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    this.mode = Objects.requireNonNull(mode);
  }

  @Override
  public void convert(SinkRecord in, Record out) {
    out.setString(TOPIC, in.topic());
    out.setBigint(PARTITION, in.kafkaPartition().longValue());
    out.setBigint(OFFSET, in.kafkaOffset());

    switch (mode) {
      case KEY:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



src/main/java/com/aliyun/odps/kafka/connect/converter/DefaultRecordConverter.java [44:54]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    this.mode = Objects.requireNonNull(mode);
  }

  @Override
  public void convert(SinkRecord in, Record out) {
    out.setString(TOPIC, in.topic());
    out.setBigint(PARTITION, in.kafkaPartition().longValue());
    out.setBigint(OFFSET, in.kafkaOffset());

    switch (mode) {
      case KEY:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -