From cc537075ab4e28bdffb2dc87a0e611cfa1fd030e Mon Sep 17 00:00:00 2001
From: George Nicolas Kontogiorgos <george.kontogiorgos@ess.eu>
Date: Fri, 16 Jun 2023 15:54:27 +0200
Subject: [PATCH] Set startup script to use Kafka broker's SSL port

---
 .gitignore  | 4 +++-
 cmds/st.cmd | 8 ++++----
 2 files changed, 7 insertions(+), 5 deletions(-)

diff --git a/.gitignore b/.gitignore
index eeaf8f9..7047b82 100644
--- a/.gitignore
+++ b/.gitignore
@@ -9,4 +9,6 @@ pv.list
 core.*
 .vscode
 list.txt
-.vscode/c_cpp_properties.json
\ No newline at end of file
+.vscode/c_cpp_properties.json
+kafka.conf
+ecdc-kafka-ca.crt
diff --git a/cmds/st.cmd b/cmds/st.cmd
index cca1e4a..c7478c7 100644
--- a/cmds/st.cmd
+++ b/cmds/st.cmd
@@ -43,13 +43,13 @@ NDStdArraysConfigure("Image1", "$(QSIZE)", 0, "$(PORT)", 0, 0)
 dbLoadRecords("NDStdArrays.template", "P=$(PREFIX),R=image1:,PORT=Image1,ADDR=0,TIMEOUT=1,NDARRAY_PORT=$(PORT),TYPE=Int32,FTVL=LONG,NELEMENTS=$(NELEMENTS)")
 
 # Create a kafka plugin, set it to get data from hama driver.
-epicsEnvSet("KFK_SERVER_IP", "10.100.1.19")
-epicsEnvSet("KFK_SERVER_PORT", "9092")
 epicsEnvSet("KFK_TOPIC", "ymir_camera")
 
-KafkaPluginConfigure("KFK1", 3, 1, "$(PORT)", 0, -1, "$(KFK_SERVER_IP):$(KFK_SERVER_PORT)", "$(KFK_TOPIC)", "hama_source")
-dbLoadRecords("$(adpluginkafka_DIR)db/adpluginkafka.db", "P=$(PREFIX), R=Kfk1:, PORT=KFK1, ADDR=0, TIMEOUT=1, NDARRAY_PORT=$(PORT)")
+# Kafka plugin
+epicsEnvSet("KFK_CONFIG_FILE_PATH", "/home/iocuser/git/adhama/cmds/kafka.conf")
 
+KafkaPluginConfigure("KFK1", 3, 1, "$(PORT)", 0, -1, "$(KFK_TOPIC)", "hama_source","$(KFK_CONFIG_FILE_PATH)")
+dbLoadRecords("$(adpluginkafka_DIR)db/adpluginkafka.db", "P=$(PREFIX), R=Kfk1:, PORT=KFK1, ADDR=0, TIMEOUT=1, NDARRAY_PORT=$(PORT)")
 
 startPVAServer