Is it possible to configure UDF’s/UDAF’s on conlfluent cloud for KSQL.
If yes, any documentation on it?
Thanks.
Is it possible to configure UDF’s/UDAF’s on conlfluent cloud for KSQL.
If yes, any documentation on it?
Thanks.
From my reading of the tutorials, it appears that you can run UDFs/UDAFs on your own deployment of ksqlDB, and can use your own deployment of ksqlDB to process topics in a Confluent Cloud Kafka cluster. What I don’t see is the ability to run UDFs/UDAFs on the hosted ksqlDB cluster.
Is it possible to run UDFs/UDAFs on a ksqlDB cluster hosted in Confluent Cloud? If not, is this in the roadmap for Confluent Cloud?
Hello Team,
I am trying to create UDFs for confluent platform KSQLDB. I followed ksqldb.io documentation for UDFs and followed steps accordingly, create Java class, assigned annotations, created executable jar of it and pasted in directory which is refernced in ksql-server.properties with name ‘ksql.extension.dir’.
Once ksql-server is up, I can describe function and can see its descriptions except variations field in description. Also, when I tried to run that function in query, it says it can not accept string parameter but in java code @UdfParameters is String as shown below.
DESCRIBE function convert;
{ "@type": "describe_function", "statementText": "DESCRIBE function convert;", "name": "CONVERT", "description": "converts json string to json data format", "author": "shubham shirur", "version": "0.0.1", "path": "/data/ext/UDFs-1.0-SNAPSHOT-jar-with-dependencies.jar", "functions": [ ], "type": "SCALAR", "warnings": [ ] }
Function ‘convert’ does not accept parameters (STRING). Valid alternatives are: For detailed information on a function run: DESCRIBE FUNCTION ; Statement: select convert(event) from TEST_EXTRACT EMIT CHANGES;
Hi David, I’m new for ksqldb and also want to deploy UDF on ksqldb in confluent cloud. Do you know if it is possible to do that?
Thank you so much,
Soon after I asked the question here, I asked Confluent support, and the answer was that UDF was not supported in Confluent Cloud. We then dropped the idea of using ksqldb. I don’t know the current situation.
Got it, Thank you so much