Package com.exoscale.sdk.model

Class JsonSchemaKafkaRest

java.lang.Object
com.exoscale.sdk.model.JsonSchemaKafkaRest
@Generated(value="org.openapitools.codegen.languages.JavaClientCodegen", comments="Generator version: 7.4.0") public class JsonSchemaKafkaRest extends Object
JsonSchemaKafkaRest

  • Field Details

    • JSON_PROPERTY_PRODUCER_COMPRESSION_TYPE

      public static final String JSON_PROPERTY_PRODUCER_COMPRESSION_TYPE
      See Also:

    • JSON_PROPERTY_NAME_STRATEGY_VALIDATION

      public static final String JSON_PROPERTY_NAME_STRATEGY_VALIDATION
      See Also:

    • JSON_PROPERTY_NAME_STRATEGY

      public static final String JSON_PROPERTY_NAME_STRATEGY
      See Also:

    • JSON_PROPERTY_CONSUMER_ENABLE_AUTO_COMMIT

      public static final String JSON_PROPERTY_CONSUMER_ENABLE_AUTO_COMMIT
      See Also:

    • JSON_PROPERTY_PRODUCER_ACKS

      public static final String JSON_PROPERTY_PRODUCER_ACKS
      See Also:

    • JSON_PROPERTY_CONSUMER_REQUEST_MAX_BYTES

      public static final String JSON_PROPERTY_CONSUMER_REQUEST_MAX_BYTES
      See Also:

    • JSON_PROPERTY_PRODUCER_MAX_REQUEST_SIZE

      public static final String JSON_PROPERTY_PRODUCER_MAX_REQUEST_SIZE
      See Also:

    • JSON_PROPERTY_SIMPLECONSUMER_POOL_SIZE_MAX

      public static final String JSON_PROPERTY_SIMPLECONSUMER_POOL_SIZE_MAX
      See Also:

    • JSON_PROPERTY_PRODUCER_LINGER_MS

      public static final String JSON_PROPERTY_PRODUCER_LINGER_MS
      See Also:

    • JSON_PROPERTY_CONSUMER_REQUEST_TIMEOUT_MS

      public static final String JSON_PROPERTY_CONSUMER_REQUEST_TIMEOUT_MS
      See Also:

  • Constructor Details

    • JsonSchemaKafkaRest

      public JsonSchemaKafkaRest()

  • Method Details

    • producerCompressionType

      public JsonSchemaKafkaRest producerCompressionType(JsonSchemaKafkaRest.ProducerCompressionTypeEnum producerCompressionType)

    • 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

    • setProducerCompressionType

      public void setProducerCompressionType(JsonSchemaKafkaRest.ProducerCompressionTypeEnum producerCompressionType)

    • nameStrategyValidation

      public JsonSchemaKafkaRest nameStrategyValidation(Boolean nameStrategyValidation)

    • 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)

    • nameStrategy

      public JsonSchemaKafkaRest nameStrategy(JsonSchemaKafkaRest.NameStrategyEnum nameStrategy)

    • getNameStrategy

      @Nullable public JsonSchemaKafkaRest.NameStrategyEnum getNameStrategy()
      Name strategy to use when selecting subject for storing schemas
      Returns:
      nameStrategy

    • setNameStrategy

      public void setNameStrategy(JsonSchemaKafkaRest.NameStrategyEnum nameStrategy)

    • consumerEnableAutoCommit

      public JsonSchemaKafkaRest consumerEnableAutoCommit(Boolean consumerEnableAutoCommit)

    • 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)

    • producerAcks

      public JsonSchemaKafkaRest producerAcks(JsonSchemaKafkaRest.ProducerAcksEnum producerAcks)

    • 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

    • setProducerAcks

      public void setProducerAcks(JsonSchemaKafkaRest.ProducerAcksEnum producerAcks)

    • consumerRequestMaxBytes

      public JsonSchemaKafkaRest consumerRequestMaxBytes(Integer consumerRequestMaxBytes)

    • 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)

    • producerMaxRequestSize

      public JsonSchemaKafkaRest producerMaxRequestSize(Integer producerMaxRequestSize)

    • 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)

    • simpleconsumerPoolSizeMax

      public JsonSchemaKafkaRest simpleconsumerPoolSizeMax(Integer simpleconsumerPoolSizeMax)

    • 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)

    • producerLingerMs

      public JsonSchemaKafkaRest producerLingerMs(Integer producerLingerMs)

    • 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)

    • consumerRequestTimeoutMs

      public JsonSchemaKafkaRest consumerRequestTimeoutMs(JsonSchemaKafkaRest.ConsumerRequestTimeoutMsEnum consumerRequestTimeoutMs)

    • 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
      Returns:
      consumerRequestTimeoutMs

    • setConsumerRequestTimeoutMs

      public void setConsumerRequestTimeoutMs(JsonSchemaKafkaRest.ConsumerRequestTimeoutMsEnum 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

    • toString

      public String toString()
      Overrides:
      toString 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