Skip to content

docs: outputs: kafka: document otlp_logs_partition_by_resource parameter#2573

Open
eschabell wants to merge 1 commit into
fluent:masterfrom
eschabell:erics_out_kafka_updates
Open

docs: outputs: kafka: document otlp_logs_partition_by_resource parameter#2573
eschabell wants to merge 1 commit into
fluent:masterfrom
eschabell:erics_out_kafka_updates

Conversation

@eschabell
Copy link
Copy Markdown
Collaborator

@eschabell eschabell commented May 15, 2026

  • Add otlp_logs_partition_by_resource boolean parameter to the configuration parameters table

Note, covers a code update without a doc update PR.

Summary by CodeRabbit

  • Documentation
    • Added otlp_logs_partition_by_resource configuration parameter for Kafka output, which controls whether logs from each OTLP resource are sent as separate Kafka messages when using otlp_json or otlp_proto formats.

Review Change Stack

  - Add `otlp_logs_partition_by_resource` boolean parameter to the
    configuration parameters table

  Note, covers a code update without a doc update PR.

Signed-off-by: Eric D. Schabell <eric@schabell.org>
@eschabell eschabell self-assigned this May 15, 2026
@eschabell eschabell added the waiting-on-review Waiting on a review from mainteners label May 15, 2026
@eschabell eschabell requested a review from a team as a code owner May 15, 2026 10:38
@coderabbitai
Copy link
Copy Markdown
Contributor

coderabbitai Bot commented May 15, 2026

📝 Walkthrough

Walkthrough

This PR adds documentation for a new Kafka output configuration parameter otlp_logs_partition_by_resource that controls whether OTLP resource-partitioned logs are sent as separate Kafka messages when using otlp_json or otlp_proto formats.

Changes

Kafka Output Parameter Documentation

Layer / File(s) Summary
Kafka OTLP partition parameter documentation
pipeline/outputs/kafka.md
Added otlp_logs_partition_by_resource parameter row to the configuration table, documenting default value (false) and its effect on OTLP log message partitioning.

Estimated code review effort

🎯 1 (Trivial) | ⏱️ ~2 minutes

Possibly related PRs

Suggested reviewers

  • patrick-stephens
  • cosmo0920

Poem

🐰 A parameter new, in docs so bright,
otlp_logs_partition_by_resource takes flight!
When logs from resources scatter and roam,
Through Kafka they journey, to data's true home.
One line, one change, documentation's delight! 📝✨

🚥 Pre-merge checks | ✅ 5
✅ Passed checks (5 passed)
Check name Status Explanation
Description Check ✅ Passed Check skipped - CodeRabbit’s high-level summary is enabled.
Title check ✅ Passed The title directly and specifically describes the main change: documenting the otlp_logs_partition_by_resource parameter for the Kafka output plugin.
Docstring Coverage ✅ Passed No functions found in the changed files to evaluate docstring coverage. Skipping docstring coverage check.
Linked Issues check ✅ Passed Check skipped because no linked issues were found for this pull request.
Out of Scope Changes check ✅ Passed Check skipped because no linked issues were found for this pull request.

✏️ Tip: You can configure your own custom pre-merge checks in the settings.

✨ Finishing Touches
🧪 Generate unit tests (beta)
  • Create PR with unit tests

Warning

Review ran into problems

🔥 Problems

Stopped waiting for pipeline failures after 30000ms. One of your pipelines takes longer than our 30000ms fetch window to run, so review may not consider pipeline-failure results for inline comments if any failures occurred after the fetch window. Increase the timeout if you want to wait longer or run a @coderabbit review after the pipeline has finished.


Thanks for using CodeRabbit! It's free for OSS, and your support helps us grow. If you like it, consider giving us a shout-out.

❤️ Share

Comment @coderabbitai help to get the list of available commands and usage tips.

Copy link
Copy Markdown
Contributor

@coderabbitai coderabbitai Bot left a comment

Choose a reason for hiding this comment

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

🧹 Nitpick comments (1)
pipeline/outputs/kafka.md (1)

27-27: 💤 Low value

Consider clarifying the boolean behavior in the description.

The description could be more explicit about what happens when the parameter is enabled versus disabled. Consider rephrasing to:

"When enabled, send logs from each OTLP resource as separate Kafka messages when using otlp_json or otlp_proto format."

This makes it clearer that the behavior described occurs when the parameter is set to true.

🤖 Prompt for AI Agents
Verify each finding against current code. Fix only still-valid issues, skip the
rest with a brief reason, keep changes minimal, and validate.

In `@pipeline/outputs/kafka.md` at line 27, Reword the description for the
otlp_logs_partition_by_resource option to explicitly state the true/false
behavior: when otlp_logs_partition_by_resource is true, send logs from each OTLP
resource as separate Kafka messages when using otlp_json or otlp_proto format;
when false, do not partition by resource (send logs as they currently are).
Update the text that currently reads "When using `otlp_json` or `otlp_proto`
format for logs, send each OTLP resource's logs as a separate Kafka message." to
the clearer phrasing referencing enabled/disabled behavior.
🤖 Prompt for all review comments with AI agents
Verify each finding against current code. Fix only still-valid issues, skip the
rest with a brief reason, keep changes minimal, and validate.

Nitpick comments:
In `@pipeline/outputs/kafka.md`:
- Line 27: Reword the description for the otlp_logs_partition_by_resource option
to explicitly state the true/false behavior: when
otlp_logs_partition_by_resource is true, send logs from each OTLP resource as
separate Kafka messages when using otlp_json or otlp_proto format; when false,
do not partition by resource (send logs as they currently are). Update the text
that currently reads "When using `otlp_json` or `otlp_proto` format for logs,
send each OTLP resource's logs as a separate Kafka message." to the clearer
phrasing referencing enabled/disabled behavior.

ℹ️ Review info
⚙️ Run configuration

Configuration used: defaults

Review profile: CHILL

Plan: Pro

Run ID: 07c1830c-106a-4916-815f-0525e95b7abd

📥 Commits

Reviewing files that changed from the base of the PR and between d40c7eb and 975b41e.

📒 Files selected for processing (1)
  • pipeline/outputs/kafka.md

@patrick-stephens
Copy link
Copy Markdown
Contributor

Be nice to have an example use case?

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

5.0.5 waiting-on-review Waiting on a review from mainteners

Projects

None yet

Development

Successfully merging this pull request may close these issues.

2 participants