Package co.com.bancolombia.factory.entrypoints

Class EntryPointKafkaStrimzi

java.lang.Object

co.com.bancolombia.factory.entrypoints.EntryPointKafkaStrimzi

All Implemented Interfaces:

ModuleFactory

public class EntryPointKafkaStrimzi
extends Object
implements ModuleFactory

Kafka consumer entry point built on Reactive Commons, validating every message against a JSON Schema stored in an Apicurio Registry.

See Also:

• Kafka Schema Validation (Apicurio)

Constructor Summary

Constructors

Constructor	Description
EntryPointKafkaStrimzi()

Method Summary

Modifier and Type	Method	Description
void	buildModule(ModuleBuilder builder)

Methods inherited from class java.lang.Object

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

Constructor Details

EntryPointKafkaStrimzi

public EntryPointKafkaStrimzi()

Method Details

buildModule

public void buildModule(ModuleBuilder builder)
                 throws IOException,
CleanException

Specified by:

buildModule in interface ModuleFactory

Throws:

IOException

CleanException