Services¶

This is an overview of all topics known to sentry-kafka-schemas, automatically generated from topic definitions.

This is an incomplete overview. Not all topics have schema definitions. Also, even if a pipeline is fully represented here, it does not mean that schemas are fully enforced in services.

Pipeline: attachments¶

        flowchart TD
    ingest-attachments[(ingest-attachments)]
    click ingest-attachments "https://github.com/getsentry/sentry-kafka-schemas/blob/main/topics/ingest-attachments.yaml" _blank
    ingest-attachments --> sentry
    relay --> ingest-attachments
    ingest-attachments-dlq[(ingest-attachments-dlq)]
    click ingest-attachments-dlq "https://github.com/getsentry/sentry-kafka-schemas/blob/main/topics/ingest-attachments-dlq.yaml" _blank
    sentry --> ingest-attachments-dlq
    click relay "https://github.com/getsentry/relay" _blank
    click sentry "https://github.com/getsentry/sentry" _blank

Pipeline: errors¶

        flowchart TD
    events[(events)]
    click events "https://github.com/getsentry/sentry-kafka-schemas/blob/main/topics/events.yaml" _blank
    events --> snuba
    events --> super-big-consumers
    sentry --> events
    ingest-events[(ingest-events)]
    click ingest-events "https://github.com/getsentry/sentry-kafka-schemas/blob/main/topics/ingest-events.yaml" _blank
    ingest-events --> sentry
    relay --> ingest-events
    ingest-events-dlq[(ingest-events-dlq)]
    click ingest-events-dlq "https://github.com/getsentry/sentry-kafka-schemas/blob/main/topics/ingest-events-dlq.yaml" _blank
    sentry --> ingest-events-dlq
    scheduled-subscriptions-events[(scheduled-subscriptions-events)]
    click scheduled-subscriptions-events "https://github.com/getsentry/sentry-kafka-schemas/blob/main/topics/scheduled-subscriptions-events.yaml" _blank
    scheduled-subscriptions-events --> snuba
    snuba --> scheduled-subscriptions-events
    event-replacements[(event-replacements)]
    click event-replacements "https://github.com/getsentry/sentry-kafka-schemas/blob/main/topics/event-replacements.yaml" _blank
    event-replacements --> snuba
    snuba --> event-replacements
    events-subscription-results[(events-subscription-results)]
    click events-subscription-results "https://github.com/getsentry/sentry-kafka-schemas/blob/main/topics/events-subscription-results.yaml" _blank
    events-subscription-results --> sentry
    snuba --> events-subscription-results
    snuba-commit-log[(snuba-commit-log)]
    click snuba-commit-log "https://github.com/getsentry/sentry-kafka-schemas/blob/main/topics/snuba-commit-log.yaml" _blank
    snuba-commit-log --> sentry
    snuba-commit-log --> snuba
    snuba --> snuba-commit-log
    ingest-events-backlog[(ingest-events-backlog)]
    click ingest-events-backlog "https://github.com/getsentry/sentry-kafka-schemas/blob/main/topics/ingest-events-backlog.yaml" _blank
    ingest-events-backlog --> sentry
    sentry --> ingest-events-backlog
    click super-big-consumers "https://github.com/getsentry/super-big-consumers" _blank
    click relay "https://github.com/getsentry/relay" _blank
    click sentry "https://github.com/getsentry/sentry" _blank
    click snuba "https://github.com/getsentry/snuba" _blank

Pipeline: generic-events¶

        flowchart TD
    ingest-occurrences[(ingest-occurrences)]
    click ingest-occurrences "https://github.com/getsentry/sentry-kafka-schemas/blob/main/topics/ingest-occurrences.yaml" _blank
    ingest-occurrences --> sentry
    sentry --> ingest-occurrences
    snuba-lw-deletions-generic-events[(snuba-lw-deletions-generic-events)]
    click snuba-lw-deletions-generic-events "https://github.com/getsentry/sentry-kafka-schemas/blob/main/topics/snuba-lw-deletions-generic-events.yaml" _blank
    snuba-lw-deletions-generic-events --> snuba
    snuba --> snuba-lw-deletions-generic-events
    snuba-generic-events-commit-log[(snuba-generic-events-commit-log)]
    click snuba-generic-events-commit-log "https://github.com/getsentry/sentry-kafka-schemas/blob/main/topics/snuba-generic-events-commit-log.yaml" _blank
    snuba-generic-events-commit-log --> sentry
    snuba-generic-events-commit-log --> snuba
    snuba --> snuba-generic-events-commit-log
    generic-events[(generic-events)]
    click generic-events "https://github.com/getsentry/sentry-kafka-schemas/blob/main/topics/generic-events.yaml" _blank
    generic-events --> snuba
    sentry --> generic-events
    snuba-dead-letter-generic-events[(snuba-dead-letter-generic-events)]
    click snuba-dead-letter-generic-events "https://github.com/getsentry/sentry-kafka-schemas/blob/main/topics/snuba-dead-letter-generic-events.yaml" _blank
    snuba --> snuba-dead-letter-generic-events
    click sentry "https://github.com/getsentry/sentry" _blank
    click snuba "https://github.com/getsentry/snuba" _blank

Pipeline: generic-metrics¶

        flowchart TD
    snuba-generic-metrics-sets-commit-log[(snuba-generic-metrics-sets-commit-log)]
    click snuba-generic-metrics-sets-commit-log "https://github.com/getsentry/sentry-kafka-schemas/blob/main/topics/snuba-generic-metrics-sets-commit-log.yaml" _blank
    snuba-generic-metrics-sets-commit-log --> sentry
    snuba-generic-metrics-sets-commit-log --> snuba
    snuba --> snuba-generic-metrics-sets-commit-log
    snuba-dead-letter-generic-metrics[(snuba-dead-letter-generic-metrics)]
    click snuba-dead-letter-generic-metrics "https://github.com/getsentry/sentry-kafka-schemas/blob/main/topics/snuba-dead-letter-generic-metrics.yaml" _blank
    snuba --> snuba-dead-letter-generic-metrics
    snuba-generic-metrics-gauges-commit-log[(snuba-generic-metrics-gauges-commit-log)]
    click snuba-generic-metrics-gauges-commit-log "https://github.com/getsentry/sentry-kafka-schemas/blob/main/topics/snuba-generic-metrics-gauges-commit-log.yaml" _blank
    snuba-generic-metrics-gauges-commit-log --> sentry
    snuba-generic-metrics-gauges-commit-log --> snuba
    snuba --> snuba-generic-metrics-gauges-commit-log
    scheduled-subscriptions-generic-metrics-distributions[(scheduled-subscriptions-generic-metrics-distributions)]
    click scheduled-subscriptions-generic-metrics-distributions "https://github.com/getsentry/sentry-kafka-schemas/blob/main/topics/scheduled-subscriptions-generic-metrics-distributions.yaml" _blank
    scheduled-subscriptions-generic-metrics-distributions --> snuba
    snuba --> scheduled-subscriptions-generic-metrics-distributions
    scheduled-subscriptions-generic-metrics-counters[(scheduled-subscriptions-generic-metrics-counters)]
    click scheduled-subscriptions-generic-metrics-counters "https://github.com/getsentry/sentry-kafka-schemas/blob/main/topics/scheduled-subscriptions-generic-metrics-counters.yaml" _blank
    scheduled-subscriptions-generic-metrics-counters --> snuba
    snuba --> scheduled-subscriptions-generic-metrics-counters
    snuba-generic-metrics-counters-commit-log[(snuba-generic-metrics-counters-commit-log)]
    click snuba-generic-metrics-counters-commit-log "https://github.com/getsentry/sentry-kafka-schemas/blob/main/topics/snuba-generic-metrics-counters-commit-log.yaml" _blank
    snuba-generic-metrics-counters-commit-log --> sentry
    snuba-generic-metrics-counters-commit-log --> snuba
    snuba --> snuba-generic-metrics-counters-commit-log
    snuba-generic-metrics-distributions-commit-log[(snuba-generic-metrics-distributions-commit-log)]
    click snuba-generic-metrics-distributions-commit-log "https://github.com/getsentry/sentry-kafka-schemas/blob/main/topics/snuba-generic-metrics-distributions-commit-log.yaml" _blank
    snuba-generic-metrics-distributions-commit-log --> sentry
    snuba-generic-metrics-distributions-commit-log --> snuba
    snuba --> snuba-generic-metrics-distributions-commit-log
    ingest-performance-metrics[(ingest-performance-metrics)]
    click ingest-performance-metrics "https://github.com/getsentry/sentry-kafka-schemas/blob/main/topics/ingest-performance-metrics.yaml" _blank
    ingest-performance-metrics --> sentry
    relay --> ingest-performance-metrics
    scheduled-subscriptions-generic-metrics-gauges[(scheduled-subscriptions-generic-metrics-gauges)]
    click scheduled-subscriptions-generic-metrics-gauges "https://github.com/getsentry/sentry-kafka-schemas/blob/main/topics/scheduled-subscriptions-generic-metrics-gauges.yaml" _blank
    scheduled-subscriptions-generic-metrics-gauges --> snuba
    snuba --> scheduled-subscriptions-generic-metrics-gauges
    snuba-generic-metrics[(snuba-generic-metrics)]
    click snuba-generic-metrics "https://github.com/getsentry/sentry-kafka-schemas/blob/main/topics/snuba-generic-metrics.yaml" _blank
    snuba-generic-metrics --> snuba
    sentry --> snuba-generic-metrics
    scheduled-subscriptions-generic-metrics-sets[(scheduled-subscriptions-generic-metrics-sets)]
    click scheduled-subscriptions-generic-metrics-sets "https://github.com/getsentry/sentry-kafka-schemas/blob/main/topics/scheduled-subscriptions-generic-metrics-sets.yaml" _blank
    scheduled-subscriptions-generic-metrics-sets --> snuba
    snuba --> scheduled-subscriptions-generic-metrics-sets
    generic-metrics-subscription-results[(generic-metrics-subscription-results)]
    click generic-metrics-subscription-results "https://github.com/getsentry/sentry-kafka-schemas/blob/main/topics/generic-metrics-subscription-results.yaml" _blank
    generic-metrics-subscription-results --> sentry
    snuba --> generic-metrics-subscription-results
    click relay "https://github.com/getsentry/relay" _blank
    click sentry "https://github.com/getsentry/sentry" _blank
    click snuba "https://github.com/getsentry/snuba" _blank

Pipeline: items¶

        flowchart TD
    scheduled-subscriptions-eap-items[(scheduled-subscriptions-eap-items)]
    click scheduled-subscriptions-eap-items "https://github.com/getsentry/sentry-kafka-schemas/blob/main/topics/scheduled-subscriptions-eap-items.yaml" _blank
    scheduled-subscriptions-eap-items --> snuba
    snuba --> scheduled-subscriptions-eap-items
    snuba-dead-letter-items[(snuba-dead-letter-items)]
    click snuba-dead-letter-items "https://github.com/getsentry/sentry-kafka-schemas/blob/main/topics/snuba-dead-letter-items.yaml" _blank
    snuba --> snuba-dead-letter-items
    snuba-items-commit-log[(snuba-items-commit-log)]
    click snuba-items-commit-log "https://github.com/getsentry/sentry-kafka-schemas/blob/main/topics/snuba-items-commit-log.yaml" _blank
    snuba-items-commit-log --> snuba
    snuba --> snuba-items-commit-log
    subscription-results-eap-items[(subscription-results-eap-items)]
    click subscription-results-eap-items "https://github.com/getsentry/sentry-kafka-schemas/blob/main/topics/subscription-results-eap-items.yaml" _blank
    subscription-results-eap-items --> sentry
    snuba --> subscription-results-eap-items
    snuba-lw-deletions-eap-items[(snuba-lw-deletions-eap-items)]
    click snuba-lw-deletions-eap-items "https://github.com/getsentry/sentry-kafka-schemas/blob/main/topics/snuba-lw-deletions-eap-items.yaml" _blank
    snuba-lw-deletions-eap-items --> snuba
    snuba --> snuba-lw-deletions-eap-items
    click sentry "https://github.com/getsentry/sentry" _blank
    click snuba "https://github.com/getsentry/snuba" _blank

Pipeline: monitors¶

        flowchart TD
    monitors-incident-occurrences[(monitors-incident-occurrences)]
    click monitors-incident-occurrences "https://github.com/getsentry/sentry-kafka-schemas/blob/main/topics/monitors-incident-occurrences.yaml" _blank
    monitors-incident-occurrences --> sentry
    sentry --> monitors-incident-occurrences
    monitors-clock-tasks[(monitors-clock-tasks)]
    click monitors-clock-tasks "https://github.com/getsentry/sentry-kafka-schemas/blob/main/topics/monitors-clock-tasks.yaml" _blank
    monitors-clock-tasks --> sentry
    sentry --> monitors-clock-tasks
    monitors-clock-tick[(monitors-clock-tick)]
    click monitors-clock-tick "https://github.com/getsentry/sentry-kafka-schemas/blob/main/topics/monitors-clock-tick.yaml" _blank
    monitors-clock-tick --> sentry
    sentry --> monitors-clock-tick
    ingest-monitors[(ingest-monitors)]
    click ingest-monitors "https://github.com/getsentry/sentry-kafka-schemas/blob/main/topics/ingest-monitors.yaml" _blank
    ingest-monitors --> sentry
    relay --> ingest-monitors
    click relay "https://github.com/getsentry/relay" _blank
    click sentry "https://github.com/getsentry/sentry" _blank

Pipeline: outcomes¶

        flowchart TD
    outcomes[(outcomes)]
    click outcomes "https://github.com/getsentry/sentry-kafka-schemas/blob/main/topics/outcomes.yaml" _blank
    outcomes --> snuba
    outcomes --> super-big-consumers
    outcomes --> sentry
    sentry --> outcomes
    relay --> outcomes
    outcomes-dlq[(outcomes-dlq)]
    click outcomes-dlq "https://github.com/getsentry/sentry-kafka-schemas/blob/main/topics/outcomes-dlq.yaml" _blank
    sentry --> outcomes-dlq
    outcomes-billing-dlq[(outcomes-billing-dlq)]
    click outcomes-billing-dlq "https://github.com/getsentry/sentry-kafka-schemas/blob/main/topics/outcomes-billing-dlq.yaml" _blank
    sentry --> outcomes-billing-dlq
    outcomes-billing[(outcomes-billing)]
    click outcomes-billing "https://github.com/getsentry/sentry-kafka-schemas/blob/main/topics/outcomes-billing.yaml" _blank
    outcomes-billing --> snuba
    outcomes-billing --> super-big-consumers
    outcomes-billing --> sentry
    sentry --> outcomes-billing
    relay --> outcomes-billing
    click super-big-consumers "https://github.com/getsentry/super-big-consumers" _blank
    click relay "https://github.com/getsentry/relay" _blank
    click sentry "https://github.com/getsentry/sentry" _blank
    click snuba "https://github.com/getsentry/snuba" _blank

Pipeline: preprod-artifacts¶

        flowchart TD
    preprod-artifact-events-dlq[(preprod-artifact-events-dlq)]
    click preprod-artifact-events-dlq "https://github.com/getsentry/sentry-kafka-schemas/blob/main/topics/preprod-artifact-events-dlq.yaml" _blank
    preprod-artifact-events-dlq --> launchpad
    launchpad --> preprod-artifact-events-dlq
    preprod-artifact-events[(preprod-artifact-events)]
    click preprod-artifact-events "https://github.com/getsentry/sentry-kafka-schemas/blob/main/topics/preprod-artifact-events.yaml" _blank
    preprod-artifact-events --> launchpad
    sentry --> preprod-artifact-events
    click launchpad "https://github.com/getsentry/launchpad" _blank
    click sentry "https://github.com/getsentry/sentry" _blank

Pipeline: profiles¶

        flowchart TD
    profiles-call-tree[(profiles-call-tree)]
    click profiles-call-tree "https://github.com/getsentry/sentry-kafka-schemas/blob/main/topics/profiles-call-tree.yaml" _blank
    profiles-call-tree --> snuba
    profiles-call-tree --> super-big-consumers
    vroom --> profiles-call-tree
    snuba-profile-chunks[(snuba-profile-chunks)]
    click snuba-profile-chunks "https://github.com/getsentry/sentry-kafka-schemas/blob/main/topics/snuba-profile-chunks.yaml" _blank
    snuba-profile-chunks --> snuba
    vroom --> snuba-profile-chunks
    processed-profiles[(processed-profiles)]
    click processed-profiles "https://github.com/getsentry/sentry-kafka-schemas/blob/main/topics/processed-profiles.yaml" _blank
    processed-profiles --> snuba
    vroom --> processed-profiles
    profiles[(profiles)]
    click profiles "https://github.com/getsentry/sentry-kafka-schemas/blob/main/topics/profiles.yaml" _blank
    profiles --> sentry
    relay --> profiles
    click relay "https://github.com/getsentry/relay" _blank
    click sentry "https://github.com/getsentry/sentry" _blank
    click super-big-consumers "https://github.com/getsentry/super-big-consumers" _blank
    click snuba "https://github.com/getsentry/snuba" _blank
    click vroom "https://github.com/getsentry/vroom" _blank

Pipeline: release-health¶

        flowchart TD
    ingest-metrics[(ingest-metrics)]
    click ingest-metrics "https://github.com/getsentry/sentry-kafka-schemas/blob/main/topics/ingest-metrics.yaml" _blank
    ingest-metrics --> sentry
    ingest-metrics --> super-big-consumers
    relay --> ingest-metrics
    snuba-metrics-commit-log[(snuba-metrics-commit-log)]
    click snuba-metrics-commit-log "https://github.com/getsentry/sentry-kafka-schemas/blob/main/topics/snuba-metrics-commit-log.yaml" _blank
    snuba-metrics-commit-log --> sentry
    snuba-metrics-commit-log --> snuba
    snuba --> snuba-metrics-commit-log
    snuba-metrics[(snuba-metrics)]
    click snuba-metrics "https://github.com/getsentry/sentry-kafka-schemas/blob/main/topics/snuba-metrics.yaml" _blank
    snuba-metrics --> snuba
    sentry --> snuba-metrics
    snuba-dead-letter-metrics[(snuba-dead-letter-metrics)]
    click snuba-dead-letter-metrics "https://github.com/getsentry/sentry-kafka-schemas/blob/main/topics/snuba-dead-letter-metrics.yaml" _blank
    snuba --> snuba-dead-letter-metrics
    ingest-metrics-dlq[(ingest-metrics-dlq)]
    click ingest-metrics-dlq "https://github.com/getsentry/sentry-kafka-schemas/blob/main/topics/ingest-metrics-dlq.yaml" _blank
    sentry --> ingest-metrics-dlq
    ingest-generic-metrics-dlq[(ingest-generic-metrics-dlq)]
    click ingest-generic-metrics-dlq "https://github.com/getsentry/sentry-kafka-schemas/blob/main/topics/ingest-generic-metrics-dlq.yaml" _blank
    sentry --> ingest-generic-metrics-dlq
    scheduled-subscriptions-metrics[(scheduled-subscriptions-metrics)]
    click scheduled-subscriptions-metrics "https://github.com/getsentry/sentry-kafka-schemas/blob/main/topics/scheduled-subscriptions-metrics.yaml" _blank
    scheduled-subscriptions-metrics --> snuba
    snuba --> scheduled-subscriptions-metrics
    metrics-subscription-results[(metrics-subscription-results)]
    click metrics-subscription-results "https://github.com/getsentry/sentry-kafka-schemas/blob/main/topics/metrics-subscription-results.yaml" _blank
    metrics-subscription-results --> sentry
    snuba --> metrics-subscription-results
    click super-big-consumers "https://github.com/getsentry/super-big-consumers" _blank
    click relay "https://github.com/getsentry/relay" _blank
    click sentry "https://github.com/getsentry/sentry" _blank
    click snuba "https://github.com/getsentry/snuba" _blank

Pipeline: replays¶

        flowchart TD
    ingest-replay-recordings[(ingest-replay-recordings)]
    click ingest-replay-recordings "https://github.com/getsentry/sentry-kafka-schemas/blob/main/topics/ingest-replay-recordings.yaml" _blank
    ingest-replay-recordings --> sentry
    relay --> ingest-replay-recordings
    snuba-dead-letter-replays[(snuba-dead-letter-replays)]
    click snuba-dead-letter-replays "https://github.com/getsentry/sentry-kafka-schemas/blob/main/topics/snuba-dead-letter-replays.yaml" _blank
    snuba --> snuba-dead-letter-replays
    ingest-replay-events[(ingest-replay-events)]
    click ingest-replay-events "https://github.com/getsentry/sentry-kafka-schemas/blob/main/topics/ingest-replay-events.yaml" _blank
    ingest-replay-events --> snuba
    ingest-replay-events --> super-big-consumers
    sentry --> ingest-replay-events
    click super-big-consumers "https://github.com/getsentry/super-big-consumers" _blank
    click relay "https://github.com/getsentry/relay" _blank
    click sentry "https://github.com/getsentry/sentry" _blank
    click snuba "https://github.com/getsentry/snuba" _blank

Pipeline: spans¶

        flowchart TD
    ingest-spans[(ingest-spans)]
    click ingest-spans "https://github.com/getsentry/sentry-kafka-schemas/blob/main/topics/ingest-spans.yaml" _blank
    ingest-spans --> sentry
    relay --> ingest-spans
    ingest-spans-dlq[(ingest-spans-dlq)]
    click ingest-spans-dlq "https://github.com/getsentry/sentry-kafka-schemas/blob/main/topics/ingest-spans-dlq.yaml" _blank
    sentry --> ingest-spans-dlq
    buffered-segments-dlq[(buffered-segments-dlq)]
    click buffered-segments-dlq "https://github.com/getsentry/sentry-kafka-schemas/blob/main/topics/buffered-segments-dlq.yaml" _blank
    sentry --> buffered-segments-dlq
    buffered-segments[(buffered-segments)]
    click buffered-segments "https://github.com/getsentry/sentry-kafka-schemas/blob/main/topics/buffered-segments.yaml" _blank
    buffered-segments --> sentry
    sentry --> buffered-segments
    click relay "https://github.com/getsentry/relay" _blank
    click sentry "https://github.com/getsentry/sentry" _blank

Pipeline: taskworker¶

        flowchart TD
    taskworker-ingest-profiling-dlq[(taskworker-ingest-profiling-dlq)]
    click taskworker-ingest-profiling-dlq "https://github.com/getsentry/sentry-kafka-schemas/blob/main/topics/taskworker-ingest-profiling-dlq.yaml" _blank
    taskworker-ingest-profiling-dlq --> taskbroker
    taskbroker --> taskworker-ingest-profiling-dlq
    taskworker-usage[(taskworker-usage)]
    click taskworker-usage "https://github.com/getsentry/sentry-kafka-schemas/blob/main/topics/taskworker-usage.yaml" _blank
    taskworker-usage --> taskbroker
    sentry --> taskworker-usage
    taskworker-billing[(taskworker-billing)]
    click taskworker-billing "https://github.com/getsentry/sentry-kafka-schemas/blob/main/topics/taskworker-billing.yaml" _blank
    taskworker-billing --> taskbroker
    sentry --> taskworker-billing
    taskworker-cutover[(taskworker-cutover)]
    click taskworker-cutover "https://github.com/getsentry/sentry-kafka-schemas/blob/main/topics/taskworker-cutover.yaml" _blank
    taskworker-cutover --> taskbroker
    sentry --> taskworker-cutover
    taskworker[(taskworker)]
    click taskworker "https://github.com/getsentry/sentry-kafka-schemas/blob/main/topics/taskworker.yaml" _blank
    taskworker --> taskbroker
    sentry --> taskworker
    taskworker-ingest-transactions[(taskworker-ingest-transactions)]
    click taskworker-ingest-transactions "https://github.com/getsentry/sentry-kafka-schemas/blob/main/topics/taskworker-ingest-transactions.yaml" _blank
    taskworker-ingest-transactions --> taskbroker
    sentry --> taskworker-ingest-transactions
    taskworker-long-dlq[(taskworker-long-dlq)]
    click taskworker-long-dlq "https://github.com/getsentry/sentry-kafka-schemas/blob/main/topics/taskworker-long-dlq.yaml" _blank
    taskworker-long-dlq --> taskbroker
    taskbroker --> taskworker-long-dlq
    taskworker-ingest-profiling[(taskworker-ingest-profiling)]
    click taskworker-ingest-profiling "https://github.com/getsentry/sentry-kafka-schemas/blob/main/topics/taskworker-ingest-profiling.yaml" _blank
    taskworker-ingest-profiling --> taskbroker
    sentry --> taskworker-ingest-profiling
    taskworker-limited[(taskworker-limited)]
    click taskworker-limited "https://github.com/getsentry/sentry-kafka-schemas/blob/main/topics/taskworker-limited.yaml" _blank
    taskworker-limited --> taskbroker
    sentry --> taskworker-limited
    taskworker-control[(taskworker-control)]
    click taskworker-control "https://github.com/getsentry/sentry-kafka-schemas/blob/main/topics/taskworker-control.yaml" _blank
    taskworker-control --> taskbroker
    sentry --> taskworker-control
    taskworker-limited-dlq[(taskworker-limited-dlq)]
    click taskworker-limited-dlq "https://github.com/getsentry/sentry-kafka-schemas/blob/main/topics/taskworker-limited-dlq.yaml" _blank
    taskworker-limited-dlq --> taskbroker
    taskbroker --> taskworker-limited-dlq
    taskworker-symbolication-dlq[(taskworker-symbolication-dlq)]
    click taskworker-symbolication-dlq "https://github.com/getsentry/sentry-kafka-schemas/blob/main/topics/taskworker-symbolication-dlq.yaml" _blank
    taskworker-symbolication-dlq --> taskbroker
    taskbroker --> taskworker-symbolication-dlq
    taskworker-ingest-dlq[(taskworker-ingest-dlq)]
    click taskworker-ingest-dlq "https://github.com/getsentry/sentry-kafka-schemas/blob/main/topics/taskworker-ingest-dlq.yaml" _blank
    taskworker-ingest-dlq --> taskbroker
    taskbroker --> taskworker-ingest-dlq
    taskworker-ingest-errors-postprocess[(taskworker-ingest-errors-postprocess)]
    click taskworker-ingest-errors-postprocess "https://github.com/getsentry/sentry-kafka-schemas/blob/main/topics/taskworker-ingest-errors-postprocess.yaml" _blank
    taskworker-ingest-errors-postprocess --> taskbroker
    sentry --> taskworker-ingest-errors-postprocess
    taskworker-billing-dlq[(taskworker-billing-dlq)]
    click taskworker-billing-dlq "https://github.com/getsentry/sentry-kafka-schemas/blob/main/topics/taskworker-billing-dlq.yaml" _blank
    taskworker-billing-dlq --> taskbroker
    taskbroker --> taskworker-billing-dlq
    taskworker-control-dlq[(taskworker-control-dlq)]
    click taskworker-control-dlq "https://github.com/getsentry/sentry-kafka-schemas/blob/main/topics/taskworker-control-dlq.yaml" _blank
    taskworker-control-dlq --> taskbroker
    taskbroker --> taskworker-control-dlq
    taskworker-dlq[(taskworker-dlq)]
    click taskworker-dlq "https://github.com/getsentry/sentry-kafka-schemas/blob/main/topics/taskworker-dlq.yaml" _blank
    taskworker-dlq --> taskbroker
    taskbroker --> taskworker-dlq
    taskworker-ingest-attachments[(taskworker-ingest-attachments)]
    click taskworker-ingest-attachments "https://github.com/getsentry/sentry-kafka-schemas/blob/main/topics/taskworker-ingest-attachments.yaml" _blank
    taskworker-ingest-attachments --> taskbroker
    sentry --> taskworker-ingest-attachments
    taskworker-long[(taskworker-long)]
    click taskworker-long "https://github.com/getsentry/sentry-kafka-schemas/blob/main/topics/taskworker-long.yaml" _blank
    taskworker-long --> taskbroker
    sentry --> taskworker-long
    taskworker-ingest-errors-dlq[(taskworker-ingest-errors-dlq)]
    click taskworker-ingest-errors-dlq "https://github.com/getsentry/sentry-kafka-schemas/blob/main/topics/taskworker-ingest-errors-dlq.yaml" _blank
    taskworker-ingest-errors-dlq --> taskbroker
    taskbroker --> taskworker-ingest-errors-dlq
    taskworker-ingest-attachments-dlq[(taskworker-ingest-attachments-dlq)]
    click taskworker-ingest-attachments-dlq "https://github.com/getsentry/sentry-kafka-schemas/blob/main/topics/taskworker-ingest-attachments-dlq.yaml" _blank
    taskworker-ingest-attachments-dlq --> taskbroker
    taskbroker --> taskworker-ingest-attachments-dlq
    taskworker-products[(taskworker-products)]
    click taskworker-products "https://github.com/getsentry/sentry-kafka-schemas/blob/main/topics/taskworker-products.yaml" _blank
    taskworker-products --> taskbroker
    sentry --> taskworker-products
    taskworker-email-dlq[(taskworker-email-dlq)]
    click taskworker-email-dlq "https://github.com/getsentry/sentry-kafka-schemas/blob/main/topics/taskworker-email-dlq.yaml" _blank
    taskworker-email-dlq --> taskbroker
    taskbroker --> taskworker-email-dlq
    taskworker-buffer[(taskworker-buffer)]
    click taskworker-buffer "https://github.com/getsentry/sentry-kafka-schemas/blob/main/topics/taskworker-buffer.yaml" _blank
    taskworker-buffer --> taskbroker
    sentry --> taskworker-buffer
    taskworker-email[(taskworker-email)]
    click taskworker-email "https://github.com/getsentry/sentry-kafka-schemas/blob/main/topics/taskworker-email.yaml" _blank
    taskworker-email --> taskbroker
    sentry --> taskworker-email
    taskworker-symbolication[(taskworker-symbolication)]
    click taskworker-symbolication "https://github.com/getsentry/sentry-kafka-schemas/blob/main/topics/taskworker-symbolication.yaml" _blank
    taskworker-symbolication --> taskbroker
    sentry --> taskworker-symbolication
    taskworker-sentryapp-dlq[(taskworker-sentryapp-dlq)]
    click taskworker-sentryapp-dlq "https://github.com/getsentry/sentry-kafka-schemas/blob/main/topics/taskworker-sentryapp-dlq.yaml" _blank
    taskworker-sentryapp-dlq --> taskbroker
    taskbroker --> taskworker-sentryapp-dlq
    taskworker-ingest[(taskworker-ingest)]
    click taskworker-ingest "https://github.com/getsentry/sentry-kafka-schemas/blob/main/topics/taskworker-ingest.yaml" _blank
    taskworker-ingest --> taskbroker
    sentry --> taskworker-ingest
    taskworker-ingest-transactions-dlq[(taskworker-ingest-transactions-dlq)]
    click taskworker-ingest-transactions-dlq "https://github.com/getsentry/sentry-kafka-schemas/blob/main/topics/taskworker-ingest-transactions-dlq.yaml" _blank
    taskworker-ingest-transactions-dlq --> taskbroker
    taskbroker --> taskworker-ingest-transactions-dlq
    taskworker-sentryapp[(taskworker-sentryapp)]
    click taskworker-sentryapp "https://github.com/getsentry/sentry-kafka-schemas/blob/main/topics/taskworker-sentryapp.yaml" _blank
    taskworker-sentryapp --> taskbroker
    sentry --> taskworker-sentryapp
    taskworker-workflows-engine[(taskworker-workflows-engine)]
    click taskworker-workflows-engine "https://github.com/getsentry/sentry-kafka-schemas/blob/main/topics/taskworker-workflows-engine.yaml" _blank
    taskworker-workflows-engine --> taskbroker
    sentry --> taskworker-workflows-engine
    taskworker-buffer-dlq[(taskworker-buffer-dlq)]
    click taskworker-buffer-dlq "https://github.com/getsentry/sentry-kafka-schemas/blob/main/topics/taskworker-buffer-dlq.yaml" _blank
    taskworker-buffer-dlq --> taskbroker
    taskbroker --> taskworker-buffer-dlq
    taskworker-ingest-errors-postprocess-dlq[(taskworker-ingest-errors-postprocess-dlq)]
    click taskworker-ingest-errors-postprocess-dlq "https://github.com/getsentry/sentry-kafka-schemas/blob/main/topics/taskworker-ingest-errors-postprocess-dlq.yaml" _blank
    taskworker-ingest-errors-postprocess-dlq --> taskbroker
    taskbroker --> taskworker-ingest-errors-postprocess-dlq
    taskworker-control-limited-dlq[(taskworker-control-limited-dlq)]
    click taskworker-control-limited-dlq "https://github.com/getsentry/sentry-kafka-schemas/blob/main/topics/taskworker-control-limited-dlq.yaml" _blank
    taskworker-control-limited-dlq --> taskbroker
    taskbroker --> taskworker-control-limited-dlq
    taskworker-ingest-errors[(taskworker-ingest-errors)]
    click taskworker-ingest-errors "https://github.com/getsentry/sentry-kafka-schemas/blob/main/topics/taskworker-ingest-errors.yaml" _blank
    taskworker-ingest-errors --> taskbroker
    sentry --> taskworker-ingest-errors
    taskworker-internal[(taskworker-internal)]
    click taskworker-internal "https://github.com/getsentry/sentry-kafka-schemas/blob/main/topics/taskworker-internal.yaml" _blank
    taskworker-internal --> taskbroker
    sentry --> taskworker-internal
    taskworker-control-limited[(taskworker-control-limited)]
    click taskworker-control-limited "https://github.com/getsentry/sentry-kafka-schemas/blob/main/topics/taskworker-control-limited.yaml" _blank
    taskworker-control-limited --> taskbroker
    sentry --> taskworker-control-limited
    taskworker-workflows-engine-dlq[(taskworker-workflows-engine-dlq)]
    click taskworker-workflows-engine-dlq "https://github.com/getsentry/sentry-kafka-schemas/blob/main/topics/taskworker-workflows-engine-dlq.yaml" _blank
    taskworker-workflows-engine-dlq --> taskbroker
    taskbroker --> taskworker-workflows-engine-dlq
    taskworker-usage-dlq[(taskworker-usage-dlq)]
    click taskworker-usage-dlq "https://github.com/getsentry/sentry-kafka-schemas/blob/main/topics/taskworker-usage-dlq.yaml" _blank
    taskworker-usage-dlq --> taskbroker
    taskbroker --> taskworker-usage-dlq
    taskworker-internal-dlq[(taskworker-internal-dlq)]
    click taskworker-internal-dlq "https://github.com/getsentry/sentry-kafka-schemas/blob/main/topics/taskworker-internal-dlq.yaml" _blank
    taskworker-internal-dlq --> taskbroker
    taskbroker --> taskworker-internal-dlq
    taskworker-products-dlq[(taskworker-products-dlq)]
    click taskworker-products-dlq "https://github.com/getsentry/sentry-kafka-schemas/blob/main/topics/taskworker-products-dlq.yaml" _blank
    taskworker-products-dlq --> taskbroker
    taskbroker --> taskworker-products-dlq
    click sentry "https://github.com/getsentry/sentry" _blank
    click taskbroker "https://github.com/getsentry/taskbroker" _blank

Pipeline: transactions¶

        flowchart TD
    scheduled-subscriptions-transactions[(scheduled-subscriptions-transactions)]
    click scheduled-subscriptions-transactions "https://github.com/getsentry/sentry-kafka-schemas/blob/main/topics/scheduled-subscriptions-transactions.yaml" _blank
    scheduled-subscriptions-transactions --> snuba
    snuba --> scheduled-subscriptions-transactions
    ingest-transactions-dlq[(ingest-transactions-dlq)]
    click ingest-transactions-dlq "https://github.com/getsentry/sentry-kafka-schemas/blob/main/topics/ingest-transactions-dlq.yaml" _blank
    sentry --> ingest-transactions-dlq
    ingest-transactions[(ingest-transactions)]
    click ingest-transactions "https://github.com/getsentry/sentry-kafka-schemas/blob/main/topics/ingest-transactions.yaml" _blank
    ingest-transactions --> sentry
    relay --> ingest-transactions
    transactions-subscription-results[(transactions-subscription-results)]
    click transactions-subscription-results "https://github.com/getsentry/sentry-kafka-schemas/blob/main/topics/transactions-subscription-results.yaml" _blank
    transactions-subscription-results --> sentry
    snuba --> transactions-subscription-results
    ingest-transactions-backlog[(ingest-transactions-backlog)]
    click ingest-transactions-backlog "https://github.com/getsentry/sentry-kafka-schemas/blob/main/topics/ingest-transactions-backlog.yaml" _blank
    ingest-transactions-backlog --> sentry
    sentry --> ingest-transactions-backlog
    snuba-transactions-commit-log[(snuba-transactions-commit-log)]
    click snuba-transactions-commit-log "https://github.com/getsentry/sentry-kafka-schemas/blob/main/topics/snuba-transactions-commit-log.yaml" _blank
    snuba-transactions-commit-log --> sentry
    snuba-transactions-commit-log --> snuba
    snuba --> snuba-transactions-commit-log
    transactions[(transactions)]
    click transactions "https://github.com/getsentry/sentry-kafka-schemas/blob/main/topics/transactions.yaml" _blank
    transactions --> snuba
    transactions --> super-big-consumers
    sentry --> transactions
    click super-big-consumers "https://github.com/getsentry/super-big-consumers" _blank
    click relay "https://github.com/getsentry/relay" _blank
    click sentry "https://github.com/getsentry/sentry" _blank
    click snuba "https://github.com/getsentry/snuba" _blank

Pipeline: uptime¶

        flowchart TD
    uptime-results[(uptime-results)]
    click uptime-results "https://github.com/getsentry/sentry-kafka-schemas/blob/main/topics/uptime-results.yaml" _blank
    uptime-results --> sentry
    uptime-checker --> uptime-results
    snuba-uptime-results[(snuba-uptime-results)]
    click snuba-uptime-results "https://github.com/getsentry/sentry-kafka-schemas/blob/main/topics/snuba-uptime-results.yaml" _blank
    snuba-uptime-results --> snuba
    sentry --> snuba-uptime-results
    click sentry "https://github.com/getsentry/sentry" _blank
    click snuba "https://github.com/getsentry/snuba" _blank
    click uptime-checker "https://github.com/getsentry/uptime-checker" _blank

Pipeline: user-feedback¶

        flowchart TD
    ingest-feedback-events-dlq[(ingest-feedback-events-dlq)]
    click ingest-feedback-events-dlq "https://github.com/getsentry/sentry-kafka-schemas/blob/main/topics/ingest-feedback-events-dlq.yaml" _blank
    sentry --> ingest-feedback-events-dlq
    ingest-feedback-events[(ingest-feedback-events)]
    click ingest-feedback-events "https://github.com/getsentry/sentry-kafka-schemas/blob/main/topics/ingest-feedback-events.yaml" _blank
    ingest-feedback-events --> sentry
    relay --> ingest-feedback-events
    click relay "https://github.com/getsentry/relay" _blank
    click sentry "https://github.com/getsentry/sentry" _blank