Skip to content

Issue 1: Inconsistent use of environment variables for Kafka SASL configuration #282

@PrinceSajjadHussain

Description

@PrinceSajjadHussain

The start_job.py file uses a different method of setting the sasl.jaas.config property for the Kafka sink compared to the aggregation_job.py file. The former constructs the config string inline within the f-string, while the latter relies on separate KAFKA_WEB_TRAFFIC_KEY and KAFKA_WEB_TRAFFIC_SECRET variables which are only used in that file and not available to the running server.py application. This inconsistency could lead to unexpected behavior or configuration errors if both jobs are deployed with differing expectations on environment variable availability.

Metadata

Metadata

Assignees

No one assigned

    Labels

    No labels
    No labels

    Type

    No type

    Projects

    No projects

    Milestone

    No milestone

    Relationships

    None yet

    Development

    No branches or pull requests

    Issue actions