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-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 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 click sentry "https://github.com/getsentry/sentry" _blank click relay "https://github.com/getsentry/relay" _blank

Pipeline: errors¶

flowchart TD 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 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 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 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 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 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 click sentry "https://github.com/getsentry/sentry" _blank click relay "https://github.com/getsentry/relay" _blank click super-big-consumers "https://github.com/getsentry/super-big-consumers" _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 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-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 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 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 click sentry "https://github.com/getsentry/sentry" _blank click snuba "https://github.com/getsentry/snuba" _blank

Pipeline: generic-metrics¶

flowchart TD 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-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 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-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 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-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 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 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 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-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 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-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 click sentry "https://github.com/getsentry/sentry" _blank click relay "https://github.com/getsentry/relay" _blank click snuba "https://github.com/getsentry/snuba" _blank

Pipeline: items¶

flowchart TD 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 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-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 click sentry "https://github.com/getsentry/sentry" _blank click snuba "https://github.com/getsentry/snuba" _blank

Pipeline: monitors¶

flowchart TD 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 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 click sentry "https://github.com/getsentry/sentry" _blank click relay "https://github.com/getsentry/relay" _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[(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 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 click sentry "https://github.com/getsentry/sentry" _blank click relay "https://github.com/getsentry/relay" _blank click super-big-consumers "https://github.com/getsentry/super-big-consumers" _blank click snuba "https://github.com/getsentry/snuba" _blank

Pipeline: profiles¶

flowchart TD 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 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 profiles[(profiles)] click profiles "https://github.com/getsentry/sentry-kafka-schemas/blob/main/topics/profiles.yaml" _blank profiles --> sentry relay --> profiles 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 click snuba "https://github.com/getsentry/snuba" _blank click vroom "https://github.com/getsentry/vroom" _blank click super-big-consumers "https://github.com/getsentry/super-big-consumers" _blank click sentry "https://github.com/getsentry/sentry" _blank click relay "https://github.com/getsentry/relay" _blank

Pipeline: release-health¶

flowchart TD 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 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 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 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 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 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 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 click sentry "https://github.com/getsentry/sentry" _blank click relay "https://github.com/getsentry/relay" _blank click super-big-consumers "https://github.com/getsentry/super-big-consumers" _blank click snuba "https://github.com/getsentry/snuba" _blank

Pipeline: replays¶

flowchart TD 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 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 click sentry "https://github.com/getsentry/sentry" _blank click relay "https://github.com/getsentry/relay" _blank click super-big-consumers "https://github.com/getsentry/super-big-consumers" _blank click snuba "https://github.com/getsentry/snuba" _blank

Pipeline: spans¶

flowchart TD snuba-eap-mutations[(snuba-eap-mutations)] click snuba-eap-mutations "https://github.com/getsentry/sentry-kafka-schemas/blob/main/topics/snuba-eap-mutations.yaml" _blank snuba-eap-mutations --> snuba sentry --> snuba-eap-mutations scheduled-subscriptions-eap-spans[(scheduled-subscriptions-eap-spans)] click scheduled-subscriptions-eap-spans "https://github.com/getsentry/sentry-kafka-schemas/blob/main/topics/scheduled-subscriptions-eap-spans.yaml" _blank scheduled-subscriptions-eap-spans --> snuba snuba --> scheduled-subscriptions-eap-spans snuba-eap-spans-commit-log[(snuba-eap-spans-commit-log)] click snuba-eap-spans-commit-log "https://github.com/getsentry/sentry-kafka-schemas/blob/main/topics/snuba-eap-spans-commit-log.yaml" _blank snuba-eap-spans-commit-log --> snuba snuba --> snuba-eap-spans-commit-log eap-spans-subscription-results[(eap-spans-subscription-results)] click eap-spans-subscription-results "https://github.com/getsentry/sentry-kafka-schemas/blob/main/topics/eap-spans-subscription-results.yaml" _blank eap-spans-subscription-results --> sentry snuba --> eap-spans-subscription-results 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 snuba-spans[(snuba-spans)] click snuba-spans "https://github.com/getsentry/sentry-kafka-schemas/blob/main/topics/snuba-spans.yaml" _blank snuba-spans --> snuba snuba-spans --> super-big-consumers sentry --> snuba-spans 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 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 click sentry "https://github.com/getsentry/sentry" _blank click relay "https://github.com/getsentry/relay" _blank click super-big-consumers "https://github.com/getsentry/super-big-consumers" _blank click snuba "https://github.com/getsentry/snuba" _blank

Pipeline: taskworker¶

flowchart TD 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-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-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-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-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-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-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-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-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 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-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-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-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-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-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-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-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-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-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-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-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-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-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-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[(taskworker)] click taskworker "https://github.com/getsentry/sentry-kafka-schemas/blob/main/topics/taskworker.yaml" _blank taskworker --> taskbroker sentry --> taskworker 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-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-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-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 click sentry "https://github.com/getsentry/sentry" _blank click taskbroker "https://github.com/getsentry/taskbroker" _blank

Pipeline: transactions¶

flowchart TD 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 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 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 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 click sentry "https://github.com/getsentry/sentry" _blank click relay "https://github.com/getsentry/relay" _blank click super-big-consumers "https://github.com/getsentry/super-big-consumers" _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 uptime-checker "https://github.com/getsentry/uptime-checker" _blank click snuba "https://github.com/getsentry/snuba" _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 sentry "https://github.com/getsentry/sentry" _blank click relay "https://github.com/getsentry/relay" _blank