Package io.confluent.kafka.schemaregistry.rules

Interface RuleAction

All Superinterfaces:

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

All Known Implementing Classes:

DlqAction, ErrorAction, NoneAction

public interface RuleAction
extends RuleBase

A post-rule action.

Field Summary

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

DEFAULT_NAME

Method Summary

Modifier and Type	Method	Description
void	run(RuleContext ctx, Object message, RuleException ex)

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

addOriginalConfigs, close, configure, setSchemaRegistryClient, type, withPluginMetrics

Method Details

run

void run(RuleContext ctx,
 Object message,
 RuleException ex)
  throws RuleException

Throws:

RuleException