diff --git a/Lab_2950_Building_a_Real_Time_Executive_KPI_Copilot_with_Confluent,_watsonx.data,_and_watsonx_BI/producer/requirements.txt b/Lab_2950_Building_a_Real_Time_Executive_KPI_Copilot_with_Confluent,_watsonx.data,_and_watsonx_BI/producer/requirements.txt
index 922a73e..f04480a 100644
--- a/Lab_2950_Building_a_Real_Time_Executive_KPI_Copilot_with_Confluent,_watsonx.data,_and_watsonx_BI/producer/requirements.txt
+++ b/Lab_2950_Building_a_Real_Time_Executive_KPI_Copilot_with_Confluent,_watsonx.data,_and_watsonx_BI/producer/requirements.txt
@@ -8,7 +8,7 @@
 # The [json,schemaregistry] extras add the Schema Registry client and the
 # JSON Schema serializer, which auto-register schemas so Apache Flink sees
 # proper columns (not raw bytes) with no manual UI inference.
-confluent-kafka[json,schemaregistry]==2.5.3
+confluent-kafka[json,schemaregistry]==2.15.1
 
 # JSON Schema validation used by the serializer.
 jsonschema>=4.0.0
diff --git a/Lab_2950_Building_a_Real_Time_Executive_KPI_Copilot_with_Confluent,_watsonx.data,_and_watsonx_BI/streamlit/requirements.txt b/Lab_2950_Building_a_Real_Time_Executive_KPI_Copilot_with_Confluent,_watsonx.data,_and_watsonx_BI/streamlit/requirements.txt
index 84e5b71..3ac0914 100644
--- a/Lab_2950_Building_a_Real_Time_Executive_KPI_Copilot_with_Confluent,_watsonx.data,_and_watsonx_BI/streamlit/requirements.txt
+++ b/Lab_2950_Building_a_Real_Time_Executive_KPI_Copilot_with_Confluent,_watsonx.data,_and_watsonx_BI/streamlit/requirements.txt
@@ -3,7 +3,7 @@
 streamlit>=1.33
 streamlit-autorefresh>=1.0.1
 # avro extra: Flink/Tableflow write the KPI topics as Avro; json for source topics
-confluent-kafka[avro,json,schemaregistry]==2.5.3
+confluent-kafka[avro,json,schemaregistry]==2.15.1
 fastavro>=1.9
 jsonschema>=4.0.0
 pandas>=2.0