We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 4e2f51a commit b0b663dCopy full SHA for b0b663d
src/handlers/http/modal/utils/ingest_utils.rs
@@ -49,6 +49,7 @@ pub async fn flatten_and_push_logs(
49
) -> Result<(), PostError> {
50
match log_source {
51
LogSource::Kinesis => {
52
+ //custom flattening required for Amazon Kinesis
53
let message: Message = serde_json::from_value(json)?;
54
for record in flatten_kinesis_logs(message) {
55
push_logs(stream_name, record, &LogSource::default()).await?;
0 commit comments