How to make the audio hearable without noise and choppy from amazon connect via kinesis video stream ?

Hi Guys,

I'm using kinesis video stream to get the audio stream from the amazon connect interaction with Lex voice bot. I'm using the getmedia API to get the file. But when I tried to convert the pcm file to any format like .wav, .mp3, .mvk etc., I cannot here the audio properly either it is choppy or with so much noisy with extended duration 1minute if the interaction itself is 30 seconds.

I'm trying in java below given the code. Please guide me into this.

public class KinesisAudioToWav {

public static void main(String[] args) {
    Region region = Region.AP_SOUTHEAST_1;
    String streamName = "streamName";

    File rawAudioFile = new File("kinesis_audio_output.pcm");
    boolean isMediaSaved = saveAudioFromKinesis(streamName, region, rawAudioFile);

    if (isMediaSaved) {
        File wavFile = new File("output.wav");
        boolean isConverted = convertPcmToWav(rawAudioFile, wavFile);
        if (isConverted) {
            System.out.println("Successfully converted to: " + wavFile.getAbsolutePath());
        } else {
            System.out.println("Conversion failed.");
        }
    } else {
        System.out.println("Failed to save media from Kinesis.");
    }
}

private static boolean saveAudioFromKinesis(String streamName, Region region, File outputFile) {
	
    String accessKey = "accesskey";
    String secretAccessKey = "secretaccesskey";
    String fragmentNumber = "fragmentNumber";

	AwsCredentialsProvider credentialsProvider = StaticCredentialsProvider.create(
			AwsBasicCredentials.create(accessKey, secretAccessKey));
    try (KinesisVideoClient kinesisVideoClient = KinesisVideoClient.builder().credentialsProvider(credentialsProvider).region(Region.AP_SOUTHEAST_1).build()) {

        GetDataEndpointRequest endpointRequest = GetDataEndpointRequest.builder()
                .streamName(streamName)
                .apiName("GET_MEDIA")
                .build();			
        GetDataEndpointResponse endpointResponse = kinesisVideoClient.getDataEndpoint(endpointRequest);
        
        KinesisVideoMediaClient mediaClient = KinesisVideoMediaClient.builder()
                .endpointOverride(URI.create(endpointResponse.dataEndpoint()))
                .region(Region.AP_SOUTHEAST_1)
                .credentialsProvider(credentialsProvider)
                .build();
        
        GetMediaRequest mediaRequest = GetMediaRequest.builder()
                .streamName(streamName)
                .startSelector(s -> s.startSelectorType("FRAGMENT_NUMBER").afterFragmentNumber(fragmentNumber))
                .build();

        try (ResponseInputStream<GetMediaResponse> mediaResponseStream = mediaClient.getMedia(mediaRequest);
             FileOutputStream fos = new FileOutputStream(outputFile)) {

            byte[] buffer = new byte[4096];
            int bytesRead;
            while ((bytesRead = mediaResponseStream.read(buffer)) != -1) {
                fos.write(buffer, 0, bytesRead);
            }
            System.out.println("Audio saved successfully to: " + outputFile.getAbsolutePath());
            return true;

        } catch (IOException e) {
            e.printStackTrace();
            return false;
        }

    } catch (Exception e) {
        e.printStackTrace();
        return false;
    }
}

private static boolean convertPcmToWav(File pcmFile, File wavFile) {
    try {

        AudioFormat audioFormat = new AudioFormat(8000, 16, 1, true, false);

        try (InputStream pcmInputStream = new BufferedInputStream(new FileInputStream(pcmFile))) {
            AudioInputStream audioInputStream = new AudioInputStream(pcmInputStream, audioFormat, pcmFile.length() / audioFormat.getFrameSize());

            AudioSystem.write(audioInputStream, AudioFileFormat.Type.WAVE, wavFile);
            System.out.println("WAV file written to: " + wavFile.getAbsolutePath());
            return true;
        }

    } catch (IOException e) {
        e.printStackTrace();
        return false;
    }
}

}