JS Executor Configuration
Queue configuration
Section titled “Queue configuration”Queue type used for JS evaluation requests: kafka or in-memory
Optional prefix applied to all queue/topic names; useful for environment isolation
Kafka topic name for incoming JS evaluation requests
HTTP port exposing the /livenessProbe health check endpoint
JavaScript execution configuration
Section titled “JavaScript execution configuration”Interval in milliseconds to poll for JS execution responses
Maximum allowed size in bytes of a JS execution result
Kafka configuration
Section titled “Kafka configuration”Kafka Bootstrap Servers
Number of replicas for each Kafka topic partition
-1 = all; 0 = no acknowledgments; 1 = only waits for the leader to acknowledge
Maximum number of messages to accumulate before triggering a batch send
Time in milliseconds the producer waits before sending a batch, allowing more messages to accumulate
(EXPERIMENTAL) increase this value if you are planning to handle more than one partition (scale up, scale down) - this will decrease the latency
Time in milliseconds to wait for a response to a Kafka request before timing out
Time in milliseconds to wait when establishing a connection to a Kafka broker
Message compression codec for the producer: none, gzip
Semicolon-separated Kafka topic configuration properties applied on topic creation
Set to true to enable Confluent Cloud-specific configuration (SSL + SASL)
Kafka client identifier; inject the pod name to easily identify the client via kafka-consumer-groups.sh
Enable SSL/TLS for Kafka broker connections
SASL mechanism for Confluent Cloud authentication: PLAIN, SCRAM-SHA-256, or SCRAM-SHA-512
Logging configuration
Section titled “Logging configuration”Log level: trace, debug, info, warn, or error
Directory path where log files are written
Log file name pattern; %DATE% is replaced with the current date
JavaScript execution and monitoring configuration
Section titled “JavaScript execution and monitoring configuration”Run scripts inside an isolated sandbox to prevent access to Node.js internals
Log memory usage every N script executions
Print execution statistics every N script executions
Log the script body every N script executions
Maximum number of compiled scripts kept in the cache
Execution time threshold in milliseconds above which a script is considered slow and logged
Log the script body when execution time exceeds slow_query_log_ms threshold