Package 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	Description
static final java.time.Duration	TIMEOUT

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	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 Details

TIMEOUT

public static final java.time.Duration TIMEOUT

Constructor Details

SpaceSynchronizationEndpointKafkaWriter

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

Method Details

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