public void convert()

in src/main/java/com/aliyun/odps/kafka/connect/converter/DefaultRecordConverter.java [48:73]

• 25 lines of code
• 8 McCabe index (conditional complexity)

  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:
        if (in.key() != null) {
          out.set(KEY, convertToString(in.key()));
        }
        break;
      case VALUE:
        if (in.value() != null) {
          out.set(VALUE, convertToString(in.value()));
        }
        break;
      case DEFAULT:
      default:
        if (in.key() != null) {
          out.set(KEY, convertToString(in.key()));
        }
        if (in.value() != null) {
          out.set(VALUE, convertToString(in.value()));
        }
    }
  }