Setting an environment variable for a (go) function in a k8s env using the admin cli

[beelis]

Hi guys,

i want to create a (go) pulsar function in a k8s environment. To set the log level, i want to set the environment variable "LOGGING_LEVEL" to "Debug". Is there an easy way i can achieve this using the pulsar admin tools? i tried it with the custom-runtime-options but that didn't work.

/pulsar/bin/pulsar-admin --admin-url $ADMIN_URL --auth-params $ADMIN_TOKEN --auth-plugin org.apache.pulsar.client.impl.auth.AuthenticationToken functions create \
  --function-config-file $CONFIG_FILE \
  --go $BIN_PATH \
  --name $FUNCTION_NAME \
  --parallelism $PARALLELISM \
  --custom-runtime-options "{\"env\": {\"LOGGING_LEVEL\": \"DEBUG\"}}"

[beelis]

After some discussion on the pulsar slack channel it seems that custom-runtime-options are only supported in the java runtime. Workaround is to define the log level in the userConfig and set the level manually in the go function:

function config file:

tenant: "functions-test"
namespace: "test-namespace"
inputs: ["persistent://functions-test/test-namespace/test_src"]
output: "persistent://functions-test/test-namespace/test_result"
userConfig:
  logLevel: "DEBUG"

setting log level in the go function:

	if logLevel, err := logrus.ParseLevel(config.LogLevel); err == nil {
		logrus.SetLevel(logLevel)
	}

[beelis]

Overview of features supported by runtime: https://pulsar.apache.org/reference/#/3.2.x/pulsar-admin/functions