def METHOD_NAME(
    group_id: str,
    auto_offset_reset: str,
    strict_offset_reset: bool,
    force_topic: Union[str, None],
    force_cluster: Union[str, None],
) -> StreamProcessor[KafkaPayload]:
    topic = force_topic or settings.KAFKA_SNUBA_GENERIC_METRICS
    bootstrap_servers = _get_bootstrap_servers(topic, force_cluster)
    return StreamProcessor(
        consumer=KafkaConsumer(
            build_kafka_consumer_configuration(
                default_config={},
                group_id=group_id,
                strict_offset_reset=strict_offset_reset,
                auto_offset_reset=auto_offset_reset,
                bootstrap_servers=bootstrap_servers,
            ),
        ),
        topic=Topic(topic),
        processor_factory=BillingMetricsConsumerStrategyFactory(),
        commit_policy=ONCE_PER_SECOND,
    )