public String getDetailType()

in src/main/java/software/amazon/event/kafkaconnector/mapping/DefaultDetailTypeMapper.java [17:22]

• 6 lines of code
• 2 McCabe index (conditional complexity)

  public String getDetailType(SinkRecord sinkRecord) {
    var detailType = eventBridgeSinkConfig.detailType;
    if (detailType != null) return detailType.replace("${topic}", sinkRecord.topic());
    return eventBridgeSinkConfig.detailTypeByTopic.getOrDefault(
        sinkRecord.topic(), AWS_DETAIL_TYPES_DEFAULT.replace("${topic}", sinkRecord.topic()));
  }