org.thales.punch.kafka.platform

Class KafkaAdminConsumer

java.lang.Object

org.thales.punch.kafka.platform.KafkaAdminConsumer

All Implemented Interfaces:

AutoCloseable, IKafkaSettingsMapConsumer

public class KafkaAdminConsumer
extends Object
implements IKafkaSettingsMapConsumer

The punch admin uses Kafka topics in particular ways. This class provides a few helper function to easily get admin consumer.

Author:

dimi

Constructor Summary

Constructors

Constructor and Description
KafkaAdminConsumer(String bootstrapServers, String topic, String groupId, String clientId, org.thales.punch.platform.api.pojo.JavaStoreSecurity securityStores) Ctor.

Method Summary

Modifier and Type	Method and Description
void	close()
byte[]	readLatestBytes(Duration timeout)
org.thales.punch.settings.api.ISettingsMap	readLatestSettingsMap(Duration timeout) Read the latest map saved in the admin topic.

Methods inherited from class java.lang.Object

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

Constructor Detail

KafkaAdminConsumer

public KafkaAdminConsumer(String bootstrapServers,
                          String topic,
                          String groupId,
                          String clientId,
                          org.thales.punch.platform.api.pojo.JavaStoreSecurity securityStores)

Ctor. This constructs the consumer but nothing is connected yet.

Parameters:

bootstrapServers - the bootstrap server address

topic - the target admin topic

groupId - the group identifier

clientId - the client identifier

Method Detail

readLatestSettingsMap

public org.thales.punch.settings.api.ISettingsMap readLatestSettingsMap(Duration timeout)
                                                                 throws TimeoutException

Read the latest map saved in the admin topic. This assumes of course what is stored in the kafka record are json maps.

Specified by:

readLatestSettingsMap in interface IKafkaSettingsMapConsumer

Parameters:

timeout - how much time you accept to wait

Returns:

the settings map.

Throws:

TimeoutException

readLatestBytes

public byte[] readLatestBytes(Duration timeout)
                       throws TimeoutException

Throws:

TimeoutException

close

public void close()

Specified by:

close in interface AutoCloseable