Package com.bakdata.kafka.streams

Class StreamsConfigX

java.lang.Object
com.bakdata.kafka.streams.StreamsConfigX
public final class StreamsConfigX extends Object
Class for simplified access to configs provided by StreamsConfig

  • Constructor Details

    • StreamsConfigX

      public StreamsConfigX(@NonNull @NonNull org.apache.kafka.streams.StreamsConfig streamsConfig)

  • Method Details

    • getAppId

      public String getAppId()
      Get the application id of the underlying StreamsConfig
      Returns:
      application id
      See Also:
      • StreamsConfig.APPLICATION_ID_CONFIG

    • getBoostrapServers

      public List<String> getBoostrapServers()
      Get the bootstrap servers of the underlying StreamsConfig
      Returns:
      list of bootstrap servers
      See Also:
      • StreamsConfig.BOOTSTRAP_SERVERS_CONFIG

    • getKafkaProperties

      public Map<String,Object> getKafkaProperties()
      Get all configs of the underlying StreamsConfig
      Returns:
      Kafka configs
      See Also:
      • AbstractConfig.originals()

    • getApplicationServer

      public Optional<org.apache.kafka.streams.state.HostInfo> getApplicationServer()
      Retrieves the host information based on the application server configuration.
      Returns:
      an Optional containing the HostInfo if the StreamsConfig.APPLICATION_SERVER_CONFIG is set; otherwise, an empty Optional.

    • getStreamsConfig

      @NonNull public @NonNull org.apache.kafka.streams.StreamsConfig getStreamsConfig()

    • equals

      public boolean equals(Object o)
      Overrides:
      equals in class Object

    • hashCode

      public int hashCode()
      Overrides:
      hashCode in class Object

    • toString

      public String toString()
      Overrides:
      toString in class Object