From 81563cdb647b8de014a59fdc7e17fcd5ebf4be6c Mon Sep 17 00:00:00 2001 From: mjkwiatkowski Date: Tue, 23 Jun 2026 13:31:05 +0200 Subject: feat: managed to successfully run experiment I --- shell_scripts/kafka_connect.sh | 4 ++++ 1 file changed, 4 insertions(+) (limited to 'shell_scripts/kafka_connect.sh') 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 -- cgit v1.2.3