Package org.frankframework.extensions.kafka

Class AbstractKafkaFacade

java.lang.Object

org.frankframework.extensions.kafka.AbstractKafkaFacade

All Implemented Interfaces:

HasPhysicalDestination, IConfigurable

Direct Known Subclasses:

KafkaListener, KafkaSender

public abstract class AbstractKafkaFacade
extends Object
implements HasPhysicalDestination, IConfigurable

Field Summary

Fields

Modifier and Type	Field	Description
protected final Properties	properties

Constructor Summary

Constructors

Constructor	Description
AbstractKafkaFacade()

Method Summary

Modifier and Type	Method	Description
protected void	checkConnection()	There's no good way to check if the Kafka cluster is available, besides using the AdminClient which we have on board anyway.
void	configure()	Configure this component.

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.frankframework.core.HasPhysicalDestination

getDomain, getPhysicalDestinationName

Field Details

properties

protected final Properties properties

Constructor Details

AbstractKafkaFacade

public AbstractKafkaFacade()

Method Details

configure

public void configure()
               throws ConfigurationException

Description copied from interface: IConfigurable

Configure this component.

configure() is called once at startup of the framework in the configure method of the owner of this IConfigurable. Purpose of this method is to check whether the static configuration of the object is correct. As much as possible class-instantiating should take place in the configure(), to improve performance.

In the case of a container, this will propagate the configure signal to all components that apply.

Specified by:

configure in interface IConfigurable

Throws:

ConfigurationException - in case it was not able to configure the component.

checkConnection

protected void checkConnection()

There's no good way to check if the Kafka cluster is available, besides using the AdminClient which we have on board anyway.