From e7d48816d25afd0e45edeb770d5b6eeaaa28ea36 Mon Sep 17 00:00:00 2001
From: Iocuser <noemail@user.com>
Date: Mon, 6 Feb 2023 13:20:07 +0100
Subject: [PATCH] Add adpluginkafka

---
 cmds/st.cmd | 11 +++++++++++
 1 file changed, 11 insertions(+)

diff --git a/cmds/st.cmd b/cmds/st.cmd
index ac29702..b693a0f 100644
--- a/cmds/st.cmd
+++ b/cmds/st.cmd
@@ -1,5 +1,6 @@
 # This should be a test startup script
 require adhama
+require adpluginkafka
 
 
 epicsEnvSet("PREFIX", "Hama:")
@@ -36,6 +37,15 @@ dbLoadRecords("$(adcore_DIR)/db/NDPva.template",  "P=$(PREFIX),R=Pva1:, PORT=PVA
 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)")
+
+
 startPVAServer
 
 #
@@ -49,6 +59,7 @@ iocInit()
 
 dbpf Hama:cam1:PoolUsedMem.SCAN 0
 dbpf Hama:image1:EnableCallbacks 1
+dbpf Hama:Kfk1:EnableCallbacks 1
 
 epicsThreadSleep(1.0)