Merge pull request #704 from atheo89/RHOAIENG-4475

Replace kafka-python with kafka-python-ng on Jupyter notebooks

jupyter/datascience/ubi9-python-3.11/Pipfile

@@ -8,7 +8,7 @@ name = "pypi"
 [packages]
 # Datascience and useful extensions
 boto3 = "~=1.35.14"
-kafka-python = "~=2.0.2"
+kafka-python-ng = "~=2.2.2"
 kfp = "~=2.9.0"
 matplotlib = "~=3.9.2"
 numpy = "~=2.1.0"

jupyter/datascience/ubi9-python-3.11/test/test_notebook.ipynb

@@ -171,7 +171,7 @@
     "class TestKafkaPython(unittest.TestCase):\n",
     "\n",
     "    def test_version(self):\n",
-    "        expected_major_minor = '2.0'\n",
+    "        expected_major_minor = '2.2'\n",
     "        actual_major_minor = get_major_minor(kafka.__version__)\n",
     "        self.assertEqual(actual_major_minor, expected_major_minor, \"incorrect version\")\n",
     "\n",

jupyter/pytorch/ubi9-python-3.11/Pipfile

@@ -18,7 +18,7 @@ torchvision = {version = "~=0.19.0", index = "pytorch"}
 
 # Datascience and useful extensions
 boto3 = "~=1.35.14"
-kafka-python = "~=2.0.2"
+kafka-python-ng = "~=2.2.2"
 kfp = "~=2.9.0"
 matplotlib = "~=3.9.2"
 numpy = "~=2.1.0"

jupyter/rocm/pytorch/ubi9-python-3.11/Pipfile

@@ -20,7 +20,7 @@ pytorch-triton-rocm = {version = "~=3.0.0", index = "pytorch"}
 
 # Datascience and useful extensions
 boto3 = "~=1.35.14"
-kafka-python = "~=2.0.2"
+kafka-python-ng = "~=2.2.2"
 kfp = "~=2.9.0"
 matplotlib = "~=3.9.2"
 numpy = "~=2.1.0"

jupyter/rocm/tensorflow/ubi9-python-3.11/Pipfile

@@ -13,7 +13,7 @@ tf2onnx = "~= 1.16.1"
 
 # Datascience and useful extensions
 boto3 = "~=1.35.14"
-kafka-python = "~=2.0.2"
+kafka-python-ng = "~=2.2.2"
 matplotlib = "~=3.9.2"
 numpy = "~=1.26.4"
 pandas = "~=2.2.2"