Package org.openspaces.persistency.kafka

Class KafkaSpaceSynchronizationEndpointConfigurer

java.lang.Object

org.openspaces.persistency.kafka.KafkaSpaceSynchronizationEndpointConfigurer

public class KafkaSpaceSynchronizationEndpointConfigurer
extends Object

Constructor Summary

Constructors

Constructor	Description
KafkaSpaceSynchronizationEndpointConfigurer()

Method Summary

Modifier and Type	Method	Description
KafkaSpaceSynchronizationEndpoint	create()
KafkaSpaceSynchronizationEndpointConfigurer	kafkaBootstrapServers(String kafkaBootstrapServers)
KafkaSpaceSynchronizationEndpointConfigurer	kafkaProperties(Properties kafkaProperties)
KafkaSpaceSynchronizationEndpointConfigurer	primaryEndpoint(SpaceSynchronizationEndpoint synchronizationEndpoint)
KafkaSpaceSynchronizationEndpointConfigurer	secondaryEndpoint(String name, SpaceSynchronizationEndpoint secondaryEndpoint)
KafkaSpaceSynchronizationEndpointConfigurer	secondaryEndpoints(Map<String,SpaceSynchronizationEndpoint> secondaryEndpoints)
KafkaSpaceSynchronizationEndpointConfigurer	topic(String topic)

Methods inherited from class java.lang.Object

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

Constructor Details

KafkaSpaceSynchronizationEndpointConfigurer

public KafkaSpaceSynchronizationEndpointConfigurer()

Method Details

primaryEndpoint

public KafkaSpaceSynchronizationEndpointConfigurer primaryEndpoint(SpaceSynchronizationEndpoint synchronizationEndpoint)

secondaryEndpoints

public KafkaSpaceSynchronizationEndpointConfigurer secondaryEndpoints(Map<String,SpaceSynchronizationEndpoint> secondaryEndpoints)

secondaryEndpoint

public KafkaSpaceSynchronizationEndpointConfigurer secondaryEndpoint(String name,
 SpaceSynchronizationEndpoint secondaryEndpoint)

kafkaBootstrapServers

public KafkaSpaceSynchronizationEndpointConfigurer kafkaBootstrapServers(String kafkaBootstrapServers)

kafkaProperties

public KafkaSpaceSynchronizationEndpointConfigurer kafkaProperties(Properties kafkaProperties)

topic

public KafkaSpaceSynchronizationEndpointConfigurer topic(String topic)

create

public KafkaSpaceSynchronizationEndpoint create()