在StreamSet平台上,spark executor控件如何获取kafka consumer控件中的数据?

图片说明
如图可知需引入脚本,那脚本中如何连接kafka consumer 以及获取数据?

https://blog.csdn.net/B11050101/article/details/78434705?locationNum=10&fps=1