Package com.exoscale.sdk.model

Class JsonSchemaKafkaRest

  • @Generated(value="org.openapitools.codegen.languages.JavaClientCodegen",
           comments="Generator version: 7.4.0")
public class JsonSchemaKafkaRest
extends Object
    JsonSchemaKafkaRest

    • Constructor Detail

      • JsonSchemaKafkaRest

        public JsonSchemaKafkaRest()

    • Method Detail

      • getProducerCompressionType

        @Nullable
public JsonSchemaKafkaRest.ProducerCompressionTypeEnum getProducerCompressionType()
        Specify the default compression type for producers. This configuration accepts the standard compression codecs ('gzip', 'snappy', 'lz4', 'zstd'). It additionally accepts 'none' which is the default and equivalent to no compression.
        Returns:
        producerCompressionType

      • getNameStrategyValidation

        @Nullable
public Boolean getNameStrategyValidation()
        If true, validate that given schema is registered under expected subject name by the used name strategy when producing messages.
        Returns:
        nameStrategyValidation

      • setNameStrategyValidation

        public void setNameStrategyValidation​(Boolean nameStrategyValidation)

      • getConsumerEnableAutoCommit

        @Nullable
public Boolean getConsumerEnableAutoCommit()
        If true the consumer's offset will be periodically committed to Kafka in the background
        Returns:
        consumerEnableAutoCommit

      • setConsumerEnableAutoCommit

        public void setConsumerEnableAutoCommit​(Boolean consumerEnableAutoCommit)

      • getProducerAcks

        @Nullable
public JsonSchemaKafkaRest.ProducerAcksEnum getProducerAcks()
        The number of acknowledgments the producer requires the leader to have received before considering a request complete. If set to 'all' or '-1', the leader will wait for the full set of in-sync replicas to acknowledge the record.
        Returns:
        producerAcks

      • getConsumerRequestMaxBytes

        @Nullable
public Integer getConsumerRequestMaxBytes()
        Maximum number of bytes in unencoded message keys and values by a single request minimum: 0 maximum: 671088640
        Returns:
        consumerRequestMaxBytes

      • setConsumerRequestMaxBytes

        public void setConsumerRequestMaxBytes​(Integer consumerRequestMaxBytes)

      • getProducerMaxRequestSize

        @Nullable
public Integer getProducerMaxRequestSize()
        The maximum size of a request in bytes. Note that Kafka broker can also cap the record batch size. minimum: 0 maximum: 2147483647
        Returns:
        producerMaxRequestSize

      • setProducerMaxRequestSize

        public void setProducerMaxRequestSize​(Integer producerMaxRequestSize)

      • getSimpleconsumerPoolSizeMax

        @Nullable
public Integer getSimpleconsumerPoolSizeMax()
        Maximum number of SimpleConsumers that can be instantiated per broker minimum: 10 maximum: 250
        Returns:
        simpleconsumerPoolSizeMax

      • setSimpleconsumerPoolSizeMax

        public void setSimpleconsumerPoolSizeMax​(Integer simpleconsumerPoolSizeMax)

      • getProducerLingerMs

        @Nullable
public Integer getProducerLingerMs()
        Wait for up to the given delay to allow batching records together minimum: 0 maximum: 5000
        Returns:
        producerLingerMs

      • setProducerLingerMs

        public void setProducerLingerMs​(Integer producerLingerMs)

      • getConsumerRequestTimeoutMs

        @Nullable
public JsonSchemaKafkaRest.ConsumerRequestTimeoutMsEnum getConsumerRequestTimeoutMs()
        The maximum total time to wait for messages for a request if the maximum number of messages has not yet been reached minimum: 1000 maximum: 30000
        Returns:
        consumerRequestTimeoutMs

      • equals

        public boolean equals​(Object o)
        Return true if this json-schema-kafka-rest object is equal to o.
        Overrides:
        equals in class Object

      • hashCode

        public int hashCode()
        Overrides:
        hashCode in class Object

      • toUrlQueryString

        public String toUrlQueryString()
        Convert the instance into URL query string.
        Returns:
        URL query string

      • toUrlQueryString

        public String toUrlQueryString​(String prefix)
        Convert the instance into URL query string.
        Parameters:
        prefix - prefix of the query string
        Returns:
        URL query string