Interface ConsumerGroupReplication.Builder

  • Method Details

    • consumerGroupsToExclude

      ConsumerGroupReplication.Builder consumerGroupsToExclude(Collection<String> consumerGroupsToExclude)

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

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

      ConsumerGroupReplication.Builder consumerGroupsToExclude(String... consumerGroupsToExclude)

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

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

      ConsumerGroupReplication.Builder consumerGroupsToReplicate(Collection<String> consumerGroupsToReplicate)

      List of regular expression patterns indicating the consumer groups to copy.

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

      ConsumerGroupReplication.Builder consumerGroupsToReplicate(String... consumerGroupsToReplicate)

      List of regular expression patterns indicating the consumer groups to copy.

      Parameters:
      consumerGroupsToReplicate - List of regular expression patterns indicating the consumer groups to copy.
      Returns:
      Returns a reference to this object so that method calls can be chained together.
    • detectAndCopyNewConsumerGroups

      ConsumerGroupReplication.Builder detectAndCopyNewConsumerGroups(Boolean detectAndCopyNewConsumerGroups)

      Enables synchronization of consumer groups to target cluster.

      Parameters:
      detectAndCopyNewConsumerGroups - Enables synchronization of consumer groups to target cluster.
      Returns:
      Returns a reference to this object so that method calls can be chained together.
    • synchroniseConsumerGroupOffsets

      ConsumerGroupReplication.Builder synchroniseConsumerGroupOffsets(Boolean synchroniseConsumerGroupOffsets)

      Enables synchronization of consumer group offsets to target cluster. The translated offsets will be written to topic __consumer_offsets.

      Parameters:
      synchroniseConsumerGroupOffsets - Enables synchronization of consumer group offsets to target cluster. The translated offsets will be written to topic __consumer_offsets.
      Returns:
      Returns a reference to this object so that method calls can be chained together.
    • consumerGroupOffsetSyncMode

      ConsumerGroupReplication.Builder consumerGroupOffsetSyncMode(String consumerGroupOffsetSyncMode)

      The consumer group offset synchronization mode. With LEGACY, offsets are synchronized when producers write to the source cluster. With ENHANCED, consumer offsets are synchronized regardless of producer location. ENHANCED requires a corresponding replicator that replicates data from the target cluster to the source cluster.

      Parameters:
      consumerGroupOffsetSyncMode - The consumer group offset synchronization mode. With LEGACY, offsets are synchronized when producers write to the source cluster. With ENHANCED, consumer offsets are synchronized regardless of producer location. ENHANCED requires a corresponding replicator that replicates data from the target cluster to the source cluster.
      Returns:
      Returns a reference to this object so that method calls can be chained together.
      See Also:
    • consumerGroupOffsetSyncMode

      ConsumerGroupReplication.Builder consumerGroupOffsetSyncMode(ConsumerGroupOffsetSyncMode consumerGroupOffsetSyncMode)

      The consumer group offset synchronization mode. With LEGACY, offsets are synchronized when producers write to the source cluster. With ENHANCED, consumer offsets are synchronized regardless of producer location. ENHANCED requires a corresponding replicator that replicates data from the target cluster to the source cluster.

      Parameters:
      consumerGroupOffsetSyncMode - The consumer group offset synchronization mode. With LEGACY, offsets are synchronized when producers write to the source cluster. With ENHANCED, consumer offsets are synchronized regardless of producer location. ENHANCED requires a corresponding replicator that replicates data from the target cluster to the source cluster.
      Returns:
      Returns a reference to this object so that method calls can be chained together.
      See Also: