Skip to content

CASSANDRA-21433: OpenTelemetry tracing initial implementation#4872

Open
yukim wants to merge 1 commit into
apache:trunkfrom
yukim:CASSANDRA-21433
Open

CASSANDRA-21433: OpenTelemetry tracing initial implementation#4872
yukim wants to merge 1 commit into
apache:trunkfrom
yukim:CASSANDRA-21433

Conversation

@yukim
Copy link
Copy Markdown
Contributor

@yukim yukim commented Jun 8, 2026

This is the implementation of CEP-32: OpenTelemetry tracing integration.

Review points

  • The way of configuring OpenTelemetry
  • Check if span name cardinality is OK
    • Coordinator span is created for Query/Prepare/Execute/Batch native protocol messages with CQLStatement#getQuerySummary() result. For example, QUERY SELECT ks.table.
    • Replica spans are created for Local read/mutation runnables and inbound messages with verb + additional info, ex. MUTATION_REQ ks.table
  • Check if attribute names and values set are OK

@michaelsembwever michaelsembwever self-requested a review June 8, 2026 10:14
Comment thread conf/cassandra.yaml
# If enabled, Cassandra can export telemetry using OpenTelemetry.
# Currently, only tracing is exported
# Default: false
opentelemetry_enabled: false
Copy link
Copy Markdown
Member

Choose a reason for hiding this comment

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

move up to start section of EXPERIMENTAL FEATURES

# If enabled, Cassandra can export telemetry using OpenTelemetry.
# Currently, only tracing is exported
# Default: false
opentelemetry_enabled: false
Copy link
Copy Markdown
Member

Choose a reason for hiding this comment

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

move up to start section of EXPERIMENTAL FEATURES

if (Span.current().getSpanContext().isValid())
{
String target = cm.getPartitionUpdates().stream()
.map((pu) -> pu.metadata().toString()).collect(Collectors.joining(" "));
Copy link
Copy Markdown
Member

Choose a reason for hiding this comment

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

performance ? (on all usages of .stream())

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