Package io.confluent.kafka.schemaregistry.rules.jsonata

Class JsonataExecutor

java.lang.Object

io.confluent.kafka.schemaregistry.rules.jsonata.JsonataExecutor

All Implemented Interfaces:

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

public class JsonataExecutor
extends Object
implements RuleExecutor

Field Summary

Fields

Modifier and Type	Field	Description
static final String	JSONATA_MAX_DEPTH
static final String	JSONATA_TIMEOUT_MS
static final String	MAX_DEPTH	Deprecated.
static final String	TIMEOUT_MS	Deprecated.
static final String	TYPE

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

DEFAULT_NAME

Constructor Summary

Constructors

Constructor	Description
JsonataExecutor()

Method Summary

Modifier and Type	Method	Description
void	configure(Map<String,?> configs)
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

Field Details

TYPE

public static final String TYPE

See Also:

• Constant Field Values

JSONATA_TIMEOUT_MS

public static final String JSONATA_TIMEOUT_MS

See Also:

• Constant Field Values

JSONATA_MAX_DEPTH

public static final String JSONATA_MAX_DEPTH

See Also:

• Constant Field Values

TIMEOUT_MS

@Deprecated
public static final String TIMEOUT_MS

Deprecated.

See Also:

• Constant Field Values

MAX_DEPTH

@Deprecated
public static final String MAX_DEPTH

Deprecated.

See Also:

• Constant Field Values

Constructor Details

JsonataExecutor

public JsonataExecutor()

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