I'm using Kafka Consumer Step to consume change events captured by Debezium. Also, the Kafka Consumer step is calling a child transformation which runs every time it receives a change event.
I'm running transformation via terminal and passing params like this:
sudo sh /full/path-to/pan.sh -file="full-path-to-ktr" -param:KTR_TO_CALL=someKtr -param:KAFKA_HOST=localhost:9092 -param:CONSUMER_GROUP=CG9 -param:TOPIC_TO_LISTEN=someTopic -param:DB_NAME=someName
I want to pass some of these params to the child transformation but this particular way is not working.
How to proceed with this?
------------------------------
Surender Pal Singh
Others
Beltech AI
------------------------------