private EventBridgeResult createPutEventsEntry()

in src/main/java/software/amazon/event/kafkaconnector/mapping/DefaultEventBridgeMapper.java [51:66]

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

  private EventBridgeResult<PutEventsRequestEntry> createPutEventsEntry(SinkRecord record) {
    try {
      return success(
          record,
          PutEventsRequestEntry.builder()
              .eventBusName(config.eventBusArn)
              .source(sourcePrefix + config.connectorId)
              .detailType(detailTypeMapper.getDetailType(record))
              .resources(config.resources)
              .detail(jsonMapper.createJsonPayload(record))
              .time(timeMapper.getTime(record))
              .build());
    } catch (Exception e) {
      return failure(record, reportOnly("Cannot convert Kafka record to EventBridge.", e));
    }
  }