@@ -51,16 +51,14 @@ pub enum KafkaTopic {
5151 Spans,
5252 /// Feedback events topic.
5353 Feedback,
54- /// Trace items for Snuba.
55- Traces,
5654}
5755
5856impl KafkaTopic {
5957 /// Returns iterator over the variants of [`KafkaTopic`].
6058 /// It will have to be adjusted if the new variants are added.
6159 pub fn iter() -> std::slice::Iter<'static, Self> {
6260 use KafkaTopic::*;
63- static TOPICS: [KafkaTopic; 15 ] = [
61+ static TOPICS: [KafkaTopic; 14 ] = [
6462 Events,
6563 Attachments,
6664 Transactions,
@@ -75,7 +73,6 @@ impl KafkaTopic {
7573 OurLogs,
7674 Spans,
7775 Feedback,
78- Traces,
7976 ];
8077 TOPICS.iter()
8178 }
@@ -141,7 +138,6 @@ define_topic_assignments! {
141138 monitors: (KafkaTopic::Monitors, "ingest-monitors", "Monitor check-ins."),
142139 spans: (KafkaTopic::Spans, "snuba-spans", "Standalone spans without a transaction."),
143140 feedback: (KafkaTopic::Feedback, "ingest-feedback-events", "Feedback events topic."),
144- traces: (KafkaTopic::Traces, "snuba-traces", "Trace items for Snuba."),
145141}
146142
147143/// Configuration for a "logical" topic/datasink that Relay should forward data into.
@@ -335,7 +331,11 @@ transactions: "ingest-transactions-kafka-topic"
335331 match topic_assignments.get(*topic) {
336332 TopicAssignment::Primary(logical_topic_name) => {
337333 if !currrently_undefined_topics.contains(logical_topic_name) {
338- assert!(sentry_kafka_schemas::get_schema(logical_topic_name, None).is_ok());
334+ assert!(
335+ sentry_kafka_schemas::get_schema(logical_topic_name, None).is_ok(),
336+ "{} is not a valid topic name",
337+ logical_topic_name
338+ );
339339 }
340340 }
341341 _ => panic!("invalid default"),
0 commit comments