org.openspaces.persistency.kafka

Class SpaceSynchronizationEndpointKafkaWriter

java.lang.Object

org.openspaces.persistency.kafka.SpaceSynchronizationEndpointKafkaWriter

All Implemented Interfaces:

Runnable

public class SpaceSynchronizationEndpointKafkaWriter
extends Object
implements Runnable

Field Summary

Fields

Modifier and Type	Field and Description
static java.time.Duration	TIMEOUT

Constructor Summary

Constructors

Constructor and Description
SpaceSynchronizationEndpointKafkaWriter(SpaceSynchronizationEndpoint spaceSynchronizationEndpoint, Properties kafkaProps, String topic, String groupName)

Method Summary

Modifier and Type	Method and Description
Map<org.apache.kafka.common.TopicPartition,org.apache.kafka.clients.consumer.OffsetAndMetadata>	getStartingPoint()
void	run()
void	setStartingPoint(Map<org.apache.kafka.common.TopicPartition,org.apache.kafka.clients.consumer.OffsetAndMetadata> startingPoint)

Methods inherited from class java.lang.Object

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

Field Detail

TIMEOUT

public static final java.time.Duration TIMEOUT

Constructor Detail

SpaceSynchronizationEndpointKafkaWriter

public SpaceSynchronizationEndpointKafkaWriter(SpaceSynchronizationEndpoint spaceSynchronizationEndpoint,
                                               Properties kafkaProps,
                                               String topic,
                                               String groupName)

Method Detail

getStartingPoint

public Map<org.apache.kafka.common.TopicPartition,org.apache.kafka.clients.consumer.OffsetAndMetadata> getStartingPoint()

setStartingPoint

public void setStartingPoint(Map<org.apache.kafka.common.TopicPartition,org.apache.kafka.clients.consumer.OffsetAndMetadata> startingPoint)

run

public void run()

Specified by:

run in interface Runnable