You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
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.