Add missing requirements.txt + fix .env

application/apache-kafka-flink-streaming/.env

@@ -2,9 +2,9 @@ CRATEDB_HOST=crate
 CRATEDB_PORT=4200
 CRATEDB_PG_PORT=5432
 
-WEATHER_PRODUCER_CITY=Viena
-WEATHER_PRODUCER_API_KEY=#USE_THE_API_KEY - https://www.weatherapi.com/
-WEATHER_PRODUCER_FETCH_EVERY_SECONDS=5
+WEATHER_PRODUCER_CITY=Vienna
+WEATHER_PRODUCER_API_KEY=#GET_THE_API_KEY - https://www.weatherapi.com/
+WEATHER_PRODUCER_FETCH_EVERY_SECONDS=30
 WEATHER_PRODUCER_KAFKA_TOPIC=weather_topic
 WEATHER_PRODUCER_KAFKA_BOOTSTRAP_SERVER=kafka
 

application/apache-kafka-flink-streaming/requirements.txt

@@ -0,0 +1,44 @@
+apache-beam==2.48.0
+apache-flink==1.18.1
+apache-flink-libraries==1.18.1
+avro-python3==1.10.2
+certifi==2024.2.2
+charset-normalizer==3.3.2
+cloudpickle==2.2.1
+crate==0.34.0
+crcmod==1.7
+dill==0.3.1.1
+dnspython==2.6.1
+docopt==0.6.2
+fastavro==1.9.4
+fasteners==0.19
+find-libpython==0.3.1
+geojson==3.1.0
+greenlet==3.0.3
+grpcio==1.62.0
+hdfs==2.7.3
+httplib2==0.22.0
+idna==3.6
+kafka-python==2.0.2
+numpy==1.24.4
+objsize==0.6.1
+orjson==3.9.15
+pandas==2.2.1
+pemja==0.3.0
+proto-plus==1.23.0
+protobuf==4.23.4
+py4j==0.10.9.7
+pyarrow==11.0.0
+pydot==1.4.2
+pymongo==4.6.2
+pyparsing==3.1.2
+python-dateutil==2.9.0.post0
+pytz==2024.1
+regex==2023.12.25
+requests==2.31.0
+six==1.16.0
+SQLAlchemy==2.0.28
+typing_extensions==4.10.0
+tzdata==2024.1
+urllib3==2.0.7
+zstandard==0.22.0