org.openspaces.persistency.kafka

Class KafkaSpaceSynchronizationEndpointConfigurer

java.lang.Object

org.openspaces.persistency.kafka.KafkaSpaceSynchronizationEndpointConfigurer

public class KafkaSpaceSynchronizationEndpointConfigurer
extends Object

Constructor Summary

Constructors

Constructor and Description
KafkaSpaceSynchronizationEndpointConfigurer()

Method Summary

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

KafkaSpaceSynchronizationEndpointConfigurer

public KafkaSpaceSynchronizationEndpointConfigurer()

Method Detail

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()