Class KafkaResourceFactory

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      protected void checkBootstrap​(java.util.Map<java.lang.String,​java.lang.Object> configs)
      Enhance the properties by calling the setBootstrapServersSupplier(Supplier) amd replace the bootstrap servers properties.
      protected java.lang.String getBootstrapServers()  
      void setBootstrapServersSupplier​(java.util.function.Supplier<java.lang.String> bootstrapServersSupplier)
      Set a supplier for the bootstrap server list to override any configured in a subclass.
      • Methods inherited from class java.lang.Object

        clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
    • Constructor Detail

      • KafkaResourceFactory

        public KafkaResourceFactory()
    • Method Detail

      • getBootstrapServers

        @Nullable
        protected java.lang.String getBootstrapServers()
      • setBootstrapServersSupplier

        public void setBootstrapServersSupplier​(java.util.function.Supplier<java.lang.String> bootstrapServersSupplier)
        Set a supplier for the bootstrap server list to override any configured in a subclass.
        Parameters:
        bootstrapServersSupplier - the supplier.
      • checkBootstrap

        protected void checkBootstrap​(java.util.Map<java.lang.String,​java.lang.Object> configs)
        Enhance the properties by calling the setBootstrapServersSupplier(Supplier) amd replace the bootstrap servers properties.
        Parameters:
        configs - the configs.