org.thales.punch.apps.shiva.kafka

Class KafkaLeaderControlPlaneController

java.lang.Object

org.thales.punch.apps.shiva.kafka.KafkaLeaderControlPlaneController

All Implemented Interfaces:

Runnable, org.thales.punch.kafka.api.IRecordHandler<String,byte[]>

public class KafkaLeaderControlPlaneController
extends Object
implements Runnable, org.thales.punch.kafka.api.IRecordHandler<String,byte[]>

This class runs the dedicated thread in charge of regularly checkking all alive workers.

Author:

dimi

Constructor Summary

Constructors

Constructor and Description
KafkaLeaderControlPlaneController(org.thales.punch.kafka.api.KafkaContinuousConsumerBuilder<String,byte[]> controlConsumerBuilder)

Method Summary

Modifier and Type	Method and Description
void	addWorker(String workerId, org.thales.punch.settings.api.ISettingsMap map)
Map<String,org.thales.punch.settings.api.ISettingsMap>	getCurrentKnownWorkers()
void	onReceive(org.thales.punch.kafka.api.IPartition partition, org.apache.kafka.clients.consumer.ConsumerRecord<String,byte[]> record)
void	reset()
void	run()
void	start()
void	stop()

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.thales.punch.kafka.api.IRecordHandler

onPartitionAssigned, onPartitionRevoked, onTick

Constructor Detail

KafkaLeaderControlPlaneController

public KafkaLeaderControlPlaneController(org.thales.punch.kafka.api.KafkaContinuousConsumerBuilder<String,byte[]> controlConsumerBuilder)

Method Detail

getCurrentKnownWorkers

public Map<String,org.thales.punch.settings.api.ISettingsMap> getCurrentKnownWorkers()

reset

public void reset()

onReceive

public void onReceive(org.thales.punch.kafka.api.IPartition partition,
                      org.apache.kafka.clients.consumer.ConsumerRecord<String,byte[]> record)

Specified by:

onReceive in interface org.thales.punch.kafka.api.IRecordHandler<String,byte[]>

run

public void run()

Specified by:

run in interface Runnable

stop

public void stop()

start

public void start()

addWorker

public void addWorker(String workerId,
                      org.thales.punch.settings.api.ISettingsMap map)