Package io.micronaut.pulsar.config

Class AbstractPulsarConfiguration<K,V>

java.lang.Object
io.micronaut.pulsar.config.AbstractPulsarConfiguration<K,V>
Type Parameters:
K - key
V - value
Direct Known Subclasses:
DefaultPulsarClientConfiguration
public abstract class AbstractPulsarConfiguration<K,V> extends Object
Base template class for configuring pulsar.
Since:
1.0
Author:
Haris Secic

  • Field Details

    • DEFAULT_PULSAR_MESSAGING_PORT

      public static final int DEFAULT_PULSAR_MESSAGING_PORT
      The default Apache Pulsar messaging port.
      See Also:

    • PREFIX

      public static final String PREFIX
      The default prefix used for Pulsar configuration.
      See Also:

    • DEFAULT_SERVER_HOST_ADDRESS

      public static final String DEFAULT_SERVER_HOST_ADDRESS
      The default server hostname or IP address.
      See Also:

    • DEFAULT_BOOTSTRAP_SERVER

      public static final String DEFAULT_BOOTSTRAP_SERVER
      The default bootstrap server address for messaging.
      See Also:

    • DEFAULT_PULSAR_AUTHENTICATION

      public static final org.apache.pulsar.client.api.Authentication DEFAULT_PULSAR_AUTHENTICATION
      By default Pulsar doesn't have any authentication.

    • TOPIC_NAME_VALIDATOR

      public static final String TOPIC_NAME_VALIDATOR
      Regex for validating topic name.
      See Also:

    • TOPIC_NAME_PATTERN_VALIDATOR

      public static final String TOPIC_NAME_PATTERN_VALIDATOR
      Regex for validating topic pattern.
      See Also:

    • TENANT_NAME_VALIDATOR

      public static final String TENANT_NAME_VALIDATOR
      See Also:

  • Constructor Details

    • AbstractPulsarConfiguration

      protected AbstractPulsarConfiguration(Properties config)

  • Method Details

    • getConfig

      @NonNull public @NonNull Properties getConfig()
      Returns:
      The Pulsar configuration