Constructor and Description |
---|
KafkaLeaderControlPlaneController(org.thales.punch.kafka.api.KafkaContinuousConsumerBuilder<String,byte[]> controlConsumerBuilder) |
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() |
public KafkaLeaderControlPlaneController(org.thales.punch.kafka.api.KafkaContinuousConsumerBuilder<String,byte[]> controlConsumerBuilder)
public Map<String,org.thales.punch.settings.api.ISettingsMap> getCurrentKnownWorkers()
public void reset()
public void onReceive(org.thales.punch.kafka.api.IPartition partition, org.apache.kafka.clients.consumer.ConsumerRecord<String,byte[]> record)
onReceive
in interface org.thales.punch.kafka.api.IRecordHandler<String,byte[]>
public void stop()
public void start()
public void addWorker(String workerId, org.thales.punch.settings.api.ISettingsMap map)
Copyright © 2022. All rights reserved.