↓ 1 callersMethodgetOpenSearchRecordAsJsonString(String correlationId, int recordNumber, String clusterId, String instanceId, String type, PostgresActivityEve
das-lambda-java-sam/das_consumer_sam_project/database_activity_streams_event_consumer_function/src/main/java/com/amazonaws/services/lambda/samples/events/das/HandlerAuroraStream.java:191