Skip to content

Commit

Permalink
rename to ingest-feedback-events
Browse files Browse the repository at this point in the history
  • Loading branch information
aliu39 committed Mar 6, 2024
1 parent 47f0b8f commit 55fede8
Show file tree
Hide file tree
Showing 3 changed files with 5 additions and 5 deletions.
4 changes: 2 additions & 2 deletions src/sentry/conf/server.py
Original file line number Diff line number Diff line change
Expand Up @@ -3463,7 +3463,7 @@ def build_cdc_postgres_init_db_volume(settings: Any) -> dict[str, dict[str, str]
KAFKA_SESSIONS_SUBSCRIPTIONS_RESULTS = "sessions-subscription-results"
KAFKA_METRICS_SUBSCRIPTIONS_RESULTS = "metrics-subscription-results"
KAFKA_INGEST_EVENTS = "ingest-events"
KAFKA_INGEST_FEEDBACKS = "ingest-feedbacks"
KAFKA_INGEST_FEEDBACK_EVENTS = "ingest-feedback-events"
KAFKA_INGEST_EVENTS_DLQ = "ingest-events-dlq"
KAFKA_INGEST_ATTACHMENTS = "ingest-attachments"
KAFKA_INGEST_TRANSACTIONS = "ingest-transactions"
Expand Down Expand Up @@ -3516,7 +3516,7 @@ def build_cdc_postgres_init_db_volume(settings: Any) -> dict[str, dict[str, str]
"sessions-subscription-results": "default",
"metrics-subscription-results": "default",
"ingest-events": "default",
"ingest-feedbacks": "default",
"ingest-feedback-events": "default",
"ingest-attachments": "default",
"ingest-transactions": "default",
"ingest-metrics": "default",
Expand Down
2 changes: 1 addition & 1 deletion src/sentry/conf/types/kafka_definition.py
Original file line number Diff line number Diff line change
Expand Up @@ -26,7 +26,7 @@ class Topic(Enum):
METRICS_SUBSCRIPTIONS_RESULTS = "metrics-subscription-results"
INGEST_EVENTS = "ingest-events"
INGEST_EVENTS_DLQ = "ingest-events-dlq"
INGEST_FEEDBACKS = "ingest-feedbacks"
INGEST_FEEDBACK_EVENTS = "ingest-feedback-events"
INGEST_ATTACHMENTS = "ingest-attachments"
INGEST_TRANSACTIONS = "ingest-transactions"
INGEST_METRICS = "ingest-metrics"
Expand Down
4 changes: 2 additions & 2 deletions src/sentry/consumers/__init__.py
Original file line number Diff line number Diff line change
Expand Up @@ -268,8 +268,8 @@ def ingest_events_options() -> list[click.Option]:
"consumer_type": "events",
},
},
"ingest-feedbacks": {
"topic": settings.KAFKA_INGEST_FEEDBACKS,
"ingest-feedback-events": {
"topic": settings.KAFKA_INGEST_FEEDBACK_EVENTS,
"strategy_factory": "sentry.ingest.consumer.factory.IngestStrategyFactory",
"click_options": ingest_events_options(),
"static_args": {
Expand Down

0 comments on commit 55fede8

Please sign in to comment.