Package io.confluent.kafka.schemaregistry.rules.cel

Class CelExecutor

java.lang.Object

io.confluent.kafka.schemaregistry.rules.cel.CelExecutor

All Implemented Interfaces:

RuleBase, RuleExecutor, AutoCloseable, org.apache.kafka.common.Configurable, org.apache.kafka.common.metrics.Monitorable

public class CelExecutor
extends Object
implements RuleExecutor

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
protected static final class	CelExecutor.Bindings	Pre-converted CEL invocation context.

Field Summary

Fields

Modifier and Type	Field	Description
static final String	CEL_IGNORE_GUARD_SEPARATOR
static final String	CEL_REGEX_ENGINE	Selects the regex engine used by the CEL matches / matches_string overloads.
static final String	TYPE

Fields inherited from interface io.confluent.kafka.schemaregistry.rules.RuleBase

DEFAULT_NAME

Constructor Summary

Constructors

Constructor	Description
CelExecutor()

Method Summary

Modifier and Type	Method	Description
protected CelExecutor.Bindings	bind(RuleContext ctx, Object obj, Map<String,Object> args)	Inspect the bound message to decide ScriptType, then convert every arg to its CEL-friendly shape.
void	configure(Map<String,?> configs)
protected Object	evaluate(RuleContext ctx, String rule, CelExecutor.Bindings b)	Look up (or compile) the program for rule and run it against the pre-converted args in b.
protected Object	evaluateWithGuard(RuleContext ctx, CelExecutor.Bindings b)	Apply the optional guard (everything before the first ; in the rule expression) and then evaluate the body.
protected Object	execute(RuleContext ctx, Object obj, Map<String,Object> args)	Entry point used by CelFieldExecutor and any subclass that wants the full guard-then-body flow.
Object	transform(RuleContext ctx, Object message)
String	type()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface io.confluent.kafka.schemaregistry.rules.RuleBase

addOriginalConfigs, close, setSchemaRegistryClient, withPluginMetrics

Field Details

TYPE

public static final String TYPE

See Also:

• Constant Field Values

CEL_IGNORE_GUARD_SEPARATOR

public static final String CEL_IGNORE_GUARD_SEPARATOR

See Also:

• Constant Field Values

CEL_REGEX_ENGINE

public static final String CEL_REGEX_ENGINE

Selects the regex engine used by the CEL matches / matches_string overloads. Values: "pcre" (Pattern, supports lookahead and other PCRE features) or "re2" (cel-java's stdlib choice, linear-time matching, no lookahead). Resolvable per-rule via params.cel.regex.engine or globally via the executor config; unconfigured falls back to CelUtils.RegexEngine.DEFAULT.

See Also:

• Constant Field Values

Constructor Details

CelExecutor

public CelExecutor()

Method Details

configure

public void configure(Map<String,?> configs)

Specified by:

configure in interface org.apache.kafka.common.Configurable

Specified by:

configure in interface RuleBase

type

public String type()

Specified by:

type in interface RuleBase

transform

public Object transform(RuleContext ctx,
 Object message)
                 throws RuleException

Specified by:

transform in interface RuleExecutor

Throws:

RuleException

execute

protected Object execute(RuleContext ctx,
 Object obj,
 Map<String,Object> args)
                  throws RuleException

Entry point used by CelFieldExecutor and any subclass that wants the full guard-then-body flow. Equivalent to bind → evaluateWithGuard.

Throws:

RuleException

bind

protected CelExecutor.Bindings bind(RuleContext ctx,
 Object obj,
 Map<String,Object> args)
                             throws RuleException

Inspect the bound message to decide ScriptType, then convert every arg to its CEL-friendly shape. The returned CelExecutor.Bindings is reusable across multiple evaluate calls (e.g., guard then body) — only the rule expression changes between them. Returns null if the message is a List (not a supported CEL binding shape).

Throws:

RuleException

evaluateWithGuard

protected Object evaluateWithGuard(RuleContext ctx,
 CelExecutor.Bindings b)
                            throws RuleException

Apply the optional guard (everything before the first ; in the rule expression) and then evaluate the body. Reuses b for both — only the rule expression (and therefore the cache key) differs.

Throws:

RuleException

evaluate

protected Object evaluate(RuleContext ctx,
 String rule,
 CelExecutor.Bindings b)
                   throws RuleException

Look up (or compile) the program for rule and run it against the pre-converted args in b.

Throws:

RuleException