Skip to content

Add max telemetry bytes#4507

Merged
Anchit Jain (anchitj) merged 3 commits intodev_kip_714from
dev_kip_714_telemetry_bytes
Dec 6, 2023
Merged

Add max telemetry bytes#4507
Anchit Jain (anchitj) merged 3 commits intodev_kip_714from
dev_kip_714_telemetry_bytes

Conversation

@anchitj
Copy link
Copy Markdown
Contributor

No description provided.

@anchitj Anchit Jain (anchitj) marked this pull request as ready for review November 22, 2023 08:18
Copy link
Copy Markdown
Contributor

@milindl Milind L (milindl) left a comment

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Looks okay - just a bunch of minor stuff

Comment thread src/rdkafka_telemetry.c Outdated
rd_kafka_log(
rk, LOG_WARNING, "TELEMETRY",
"Metrics payload size %" PRIdsz
" exceeds telemetry_max_bytes %d specified by the broker.",
Copy link
Copy Markdown
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

The format string will PRId32 for int32

Copy link
Copy Markdown
Contributor Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Updated

Comment thread src/rdkafka_telemetry.c Outdated
"PushTelemetryRequest failed: %s",
rd_kafka_err2str(err));
// Non-retriable errors
// TODO: What to do for TELEMETRY_TOO_LARGE?
Copy link
Copy Markdown
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

I guess we can just add a comment. Or at max a log (even though we will have logged a warning already), based on the discussion with the Java clients team, we need to do nothing special.

Copy link
Copy Markdown
Contributor Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Removed the comment

@anchitj Anchit Jain (anchitj) force-pushed the dev_kip_714_telemetry_bytes branch from 0230c2c to a6b31a4 Compare December 5, 2023 10:51
@milindl
Copy link
Copy Markdown
Contributor

LGTM

@anchitj Anchit Jain (anchitj) merged commit 81913fe into dev_kip_714 Dec 6, 2023
@anchitj Anchit Jain (anchitj) deleted the dev_kip_714_telemetry_bytes branch December 6, 2023 07:34
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

2 participants