Interface TopicReplication.Builder

All Superinterfaces:
Buildable, CopyableBuilder<TopicReplication.Builder,TopicReplication>, SdkBuilder<TopicReplication.Builder,TopicReplication>, SdkPojo
Enclosing class:
TopicReplication
@Mutable @NotThreadSafe public static interface TopicReplication.Builder extends SdkPojo, CopyableBuilder<TopicReplication.Builder,TopicReplication>

  • Method Details

    • copyAccessControlListsForTopics

      TopicReplication.Builder copyAccessControlListsForTopics(Boolean copyAccessControlListsForTopics)

      Whether to periodically configure remote topic ACLs to match their corresponding upstream topics.

      Parameters:
      copyAccessControlListsForTopics - Whether to periodically configure remote topic ACLs to match their corresponding upstream topics.
      Returns:
      Returns a reference to this object so that method calls can be chained together.

    • copyTopicConfigurations

      TopicReplication.Builder copyTopicConfigurations(Boolean copyTopicConfigurations)

      Whether to periodically configure remote topics to match their corresponding upstream topics.

      Parameters:
      copyTopicConfigurations - Whether to periodically configure remote topics to match their corresponding upstream topics.
      Returns:
      Returns a reference to this object so that method calls can be chained together.

    • detectAndCopyNewTopics

      TopicReplication.Builder detectAndCopyNewTopics(Boolean detectAndCopyNewTopics)

      Whether to periodically check for new topics and partitions.

      Parameters:
      detectAndCopyNewTopics - Whether to periodically check for new topics and partitions.
      Returns:
      Returns a reference to this object so that method calls can be chained together.

    • startingPosition

      TopicReplication.Builder startingPosition(ReplicationStartingPosition startingPosition)

      Configuration for specifying the position in the topics to start replicating from.

      Parameters:
      startingPosition - Configuration for specifying the position in the topics to start replicating from.
      Returns:
      Returns a reference to this object so that method calls can be chained together.

    • startingPosition

      default TopicReplication.Builder startingPosition(Consumer<ReplicationStartingPosition.Builder> startingPosition)

      Configuration for specifying the position in the topics to start replicating from.

      This is a convenience method that creates an instance of the ReplicationStartingPosition.Builder avoiding the need to create one manually via ReplicationStartingPosition.builder().

      When the Consumer completes, SdkBuilder.build() is called immediately and its result is passed to startingPosition(ReplicationStartingPosition).

      Parameters:
      startingPosition - a consumer that will call methods on ReplicationStartingPosition.Builder
      Returns:
      Returns a reference to this object so that method calls can be chained together.
      See Also:

    • topicNameConfiguration

      TopicReplication.Builder topicNameConfiguration(ReplicationTopicNameConfiguration topicNameConfiguration)

      Configuration for specifying replicated topic names should be the same as their corresponding upstream topics or prefixed with source cluster alias.

      Parameters:
      topicNameConfiguration - Configuration for specifying replicated topic names should be the same as their corresponding upstream topics or prefixed with source cluster alias.
      Returns:
      Returns a reference to this object so that method calls can be chained together.

    • topicNameConfiguration

      default TopicReplication.Builder topicNameConfiguration(Consumer<ReplicationTopicNameConfiguration.Builder> topicNameConfiguration)

      Configuration for specifying replicated topic names should be the same as their corresponding upstream topics or prefixed with source cluster alias.

      This is a convenience method that creates an instance of the ReplicationTopicNameConfiguration.Builder avoiding the need to create one manually via ReplicationTopicNameConfiguration.builder().

      When the Consumer completes, SdkBuilder.build() is called immediately and its result is passed to topicNameConfiguration(ReplicationTopicNameConfiguration).

      Parameters:
      topicNameConfiguration - a consumer that will call methods on ReplicationTopicNameConfiguration.Builder
      Returns:
      Returns a reference to this object so that method calls can be chained together.
      See Also:

    • topicsToExclude

      TopicReplication.Builder topicsToExclude(Collection<String> topicsToExclude)

      List of regular expression patterns indicating the topics that should not be replicated.

      Parameters:
      topicsToExclude - List of regular expression patterns indicating the topics that should not be replicated.
      Returns:
      Returns a reference to this object so that method calls can be chained together.

    • topicsToExclude

      TopicReplication.Builder topicsToExclude(String... topicsToExclude)

      List of regular expression patterns indicating the topics that should not be replicated.

      Parameters:
      topicsToExclude - List of regular expression patterns indicating the topics that should not be replicated.
      Returns:
      Returns a reference to this object so that method calls can be chained together.

    • topicsToReplicate

      TopicReplication.Builder topicsToReplicate(Collection<String> topicsToReplicate)

      List of regular expression patterns indicating the topics to copy.

      Parameters:
      topicsToReplicate - List of regular expression patterns indicating the topics to copy.
      Returns:
      Returns a reference to this object so that method calls can be chained together.

    • topicsToReplicate

      TopicReplication.Builder topicsToReplicate(String... topicsToReplicate)

      List of regular expression patterns indicating the topics to copy.

      Parameters:
      topicsToReplicate - List of regular expression patterns indicating the topics to copy.
      Returns:
      Returns a reference to this object so that method calls can be chained together.