org.thales.punch.kafka.platform

Class KafkaConfigurationStoreImpl

java.lang.Object

org.thales.punch.kafka.platform.KafkaConfigurationStoreImpl

All Implemented Interfaces:

AutoCloseable, org.thales.punch.settings.api.IConfigurationStore

public class KafkaConfigurationStoreImpl
extends Object
implements org.thales.punch.settings.api.IConfigurationStore

This store is implemented onto a single compacted Kafka topic.

Author:

dimi

Constructor Summary

Constructors

Constructor and Description
KafkaConfigurationStoreImpl(String bootstrapServers, String topic, org.thales.punch.platform.api.pojo.JavaStoreSecurity securityStores)

Method Summary

Modifier and Type	Method and Description
boolean	checkIfPathExist(String path)
void	close()
org.thales.punch.settings.api.ISettingsMap	readMap(String path)
void	refresh()
void	rmr(String path)
org.thales.punch.settings.api.IConfigurationStore	startBlocking()
void	writeMap(org.thales.punch.settings.api.ISettingsMap value, String path)

Methods inherited from class java.lang.Object

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

Constructor Detail

KafkaConfigurationStoreImpl

public KafkaConfigurationStoreImpl(String bootstrapServers,
                                   String topic,
                                   org.thales.punch.platform.api.pojo.JavaStoreSecurity securityStores)
                            throws TimeoutException

Parameters:

bootstrapServers - the bootstrap server address

topic - the topic name

securityStores - the Object containing the truststore and keystore information. If not null, activate ssl.

Throws:

TimeoutException

Method Detail

refresh

public void refresh()
             throws TimeoutException

Specified by:

refresh in interface org.thales.punch.settings.api.IConfigurationStore

Throws:

TimeoutException

readMap

public org.thales.punch.settings.api.ISettingsMap readMap(String path)

Specified by:

readMap in interface org.thales.punch.settings.api.IConfigurationStore

writeMap

public void writeMap(org.thales.punch.settings.api.ISettingsMap value,
                     String path)

Specified by:

writeMap in interface org.thales.punch.settings.api.IConfigurationStore

startBlocking

public org.thales.punch.settings.api.IConfigurationStore startBlocking()

Specified by:

startBlocking in interface org.thales.punch.settings.api.IConfigurationStore

close

public void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface org.thales.punch.settings.api.IConfigurationStore

checkIfPathExist

public boolean checkIfPathExist(String path)

Specified by:

checkIfPathExist in interface org.thales.punch.settings.api.IConfigurationStore

rmr

public void rmr(String path)

Specified by:

rmr in interface org.thales.punch.settings.api.IConfigurationStore