summaryrefslogtreecommitdiff
path: root/shell_scripts/kafka_connect.sh
diff options
context:
space:
mode:
authormjkwiatkowski <mati.rewa@gmail.com>2026-06-23 13:31:05 +0200
committermjkwiatkowski <mati.rewa@gmail.com>2026-06-23 13:31:05 +0200
commit81563cdb647b8de014a59fdc7e17fcd5ebf4be6c (patch)
tree631cd8ff1f3f77d29739c7e1a06347a327caa7e7 /shell_scripts/kafka_connect.sh
parentca0c72789ba87791829001d259000b2966d9d6e4 (diff)
feat: managed to successfully run experiment I
Diffstat (limited to 'shell_scripts/kafka_connect.sh')
-rwxr-xr-xshell_scripts/kafka_connect.sh4
1 files changed, 4 insertions, 0 deletions
diff --git a/shell_scripts/kafka_connect.sh b/shell_scripts/kafka_connect.sh
index 3f22b6de..fecc8f63 100755
--- a/shell_scripts/kafka_connect.sh
+++ b/shell_scripts/kafka_connect.sh
@@ -1,2 +1,6 @@
#!/bin/bash
/opt/confluent/bin/connect-standalone /opt/confluent/etc/kafka/connect-standalone.properties /opt/confluent/share/confluent-common/connectors/sink-jdbc.properties /opt/confluent/share/confluent-common/connectors/sink-redis.properties
+# Considerable effort has gone into filtering messages in situ. Please refer to:
+# https://forum.confluent.io/t/invalid-value-for-filter-in-smt/10046
+# https://github.com/json-path/JsonPath
+# https://docs.confluent.io/kafka-connectors/transforms/current/filter-confluent.html#properties