diff --git a/debezium/scripts/demo.py b/debezium/scripts/demo.py
index 7bf0e91cb37..7490ffa497e 100644
--- a/debezium/scripts/demo.py
+++ b/debezium/scripts/demo.py
@@ -3,9 +3,7 @@
 import deephaven.ProduceKafka as pk
 import deephaven.Types as dh
 from deephaven import Aggregation as agg, as_list
-from deephaven import PythonFunction as pyfun
 import deephaven.TableManipulation.WindowCheck as wck
-import jpy
 
 server_name = 'mysql'
 db_name='shop'