Feature - Aggregate event stream inspection

[stefanmirkovic]

No description provided.

[CodeDrivenMitch]

LGTM. As discussed, we might want to do follow-up PRs for propagating dlq and entity state limitations

[CodeDrivenMitch]

With this extension function:

private fun String?.truncate(i: Int): String? {
        if(this == null || this.length <= i) {
            return this
        }
        return this.substring(0, i) + "... [truncated to $i characters]"
    }

We can do here:

Suggested change

	serializer.serialize(event.payload, String::class.java).data
	serializer.serialize(event.payload, String::class.java).data.truncate(50*1024)

[CodeDrivenMitch]

A double let with overshadowing it generally is not the best practice. Please name the it :)

In addition, with the extension function to truncate:

Suggested change

	state = it
	state = state.truncate(2 * 1024 * 1024) // truncate to 2MB

[sonarqubecloud]

Quality Gate passed

Issues
2 New issues
0 Accepted issues

Measures
0 Security Hotspots
0.0% Coverage on New Code
0.0% Duplication on New Code

See analysis details on SonarQube Cloud