remove extra configs from mut factory

getsentry · Sep 11, 2024 · ce103b5 · ce103b5
1 parent a75ee46
commit ce103b5
Show file tree

Hide file tree

Showing 2 changed files with 0 additions and 6 deletions.
diff --git a/rust_snuba/src/consumer.rs b/rust_snuba/src/consumer.rs
@@ -243,15 +243,12 @@ pub fn consumer_impl(
             max_batch_time,
             processing_concurrency: ConcurrencyConfig::new(concurrency),
             clickhouse_concurrency: ConcurrencyConfig::new(clickhouse_concurrency),
-            commitlog_concurrency: ConcurrencyConfig::new(2),
-            replacements_concurrency: ConcurrencyConfig::new(4),
             async_inserts,
             python_max_queue_depth,
             use_rust_processor,
             health_check_file: health_check_file.map(ToOwned::to_owned),
             enforce_schema,
             commit_log_producer,
-            replacements_config,
             physical_consumer_group: consumer_group.to_owned(),
             physical_topic_name: Topic::new(&consumer_config.raw_topic.physical_topic_name),
             accountant_topic_config: consumer_config.accountant_topic,

diff --git a/rust_snuba/src/mutations_factory.rs b/rust_snuba/src/mutations_factory.rs
@@ -27,15 +27,12 @@ pub struct MutConsumerStrategyFactory {
     pub max_batch_time: Duration,
     pub processing_concurrency: ConcurrencyConfig,
     pub clickhouse_concurrency: ConcurrencyConfig,
-    pub commitlog_concurrency: ConcurrencyConfig,
-    pub replacements_concurrency: ConcurrencyConfig,
     pub async_inserts: bool,
     pub python_max_queue_depth: Option<usize>,
     pub use_rust_processor: bool,
     pub health_check_file: Option<String>,
     pub enforce_schema: bool,
     pub commit_log_producer: Option<(Arc<KafkaProducer>, Topic)>,
-    pub replacements_config: Option<(KafkaConfig, Topic)>,
     pub physical_consumer_group: String,
     pub physical_topic_name: Topic,
     pub accountant_topic_config: config::TopicConfig,