org.thales.punch.apps.shiva.kafka

Class KafkaWorkerController

java.lang.Object

org.thales.punch.apps.shiva.kafka.KafkaWorkerController

All Implemented Interfaces:

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

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

Constructor Summary

Constructors

Constructor and Description
KafkaWorkerController(String bootstrapServers, org.apache.kafka.clients.producer.KafkaProducer<String,byte[]> producer, String clusterName, String commandTopic, String assignementTopic, String controlTopic, IWorker worker, long tickInterval, org.thales.punch.platform.api.pojo.JavaStoreSecurity securityStores)

Method Summary

Modifier and Type	Method and Description
void	onPartitionAssigned(org.thales.punch.kafka.api.IPartition partition, org.apache.kafka.clients.consumer.OffsetAndMetadata offsetAndMetadata)
void	onPartitionRevoked(org.thales.punch.kafka.api.IPartition partition)
void	onReceive(org.thales.punch.kafka.api.IPartition partition, org.apache.kafka.clients.consumer.ConsumerRecord<String,byte[]> record)
void	onTick(org.thales.punch.kafka.api.IPartition partition, long nextOffsetToRead)
void	run()

Methods inherited from class java.lang.Object

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

Constructor Detail

KafkaWorkerController

public KafkaWorkerController(String bootstrapServers,
                             org.apache.kafka.clients.producer.KafkaProducer<String,byte[]> producer,
                             String clusterName,
                             String commandTopic,
                             String assignementTopic,
                             String controlTopic,
                             IWorker worker,
                             long tickInterval,
                             org.thales.punch.platform.api.pojo.JavaStoreSecurity securityStores)

Method Detail

run

public void run()

Specified by:

run in interface Runnable

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[]>

onTick

public void onTick(org.thales.punch.kafka.api.IPartition partition,
                   long nextOffsetToRead)

Specified by:

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

onPartitionAssigned

public void onPartitionAssigned(org.thales.punch.kafka.api.IPartition partition,
                                org.apache.kafka.clients.consumer.OffsetAndMetadata offsetAndMetadata)

Specified by:

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

onPartitionRevoked

public void onPartitionRevoked(org.thales.punch.kafka.api.IPartition partition)

Specified by:

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