Class KafkaSettings.Builder

    • Constructor Detail

      • Builder

        public Builder()
    • Method Detail

      • bootstrapServers

        public KafkaSettings.Builder bootstrapServers​(String bootstrapServers)
        Bootstrap servers.
        Parameters:
        bootstrapServers - the value to set
        Returns:
        this builder
      • autoCreateTopicsEnable

        public KafkaSettings.Builder autoCreateTopicsEnable​(Boolean autoCreateTopicsEnable)
        Enable auto creation of topic on the server.
        Parameters:
        autoCreateTopicsEnable - the value to set
        Returns:
        this builder
      • logRetentionHours

        public KafkaSettings.Builder logRetentionHours​(Integer logRetentionHours)
        The number of hours to keep a log file before deleting it (in hours).
        Parameters:
        logRetentionHours - the value to set
        Returns:
        this builder
      • numPartitions

        public KafkaSettings.Builder numPartitions​(Integer numPartitions)
        The default number of log partitions per topic.
        Parameters:
        numPartitions - the value to set
        Returns:
        this builder