Kafka Rest Settings
Properties
| Property | Type | Required | Description |
|---|---|---|---|
consumer_enable_auto_commit | boolean | no | If true the consumer’s offset will be periodically committed to Kafka in the background |
consumer_request_max_bytes | integer | no | Maximum number of bytes in unencoded message keys and values by a single request |
consumer_request_timeout_ms | integer | no | The maximum total time to wait for messages for a request if the maximum number of messages has not yet been reached Allowed values: 1000, 15000, 30000. |
name_strategy | string | no | Name strategy to use when selecting subject for storing schemas Allowed values: topic_name, record_name, topic_record_name. |
name_strategy_validation | boolean | no | If true, validate that given schema is registered under expected subject name by the used name strategy when producing messages. |
producer_acks | string | no | 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. Allowed values: all, -1, 0, 1. |
producer_compression_type | string | no | 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. Allowed values: gzip, snappy, lz4, zstd, none. |
producer_linger_ms | integer | no | Wait for up to the given delay to allow batching records together |
producer_max_request_size | integer | no | The maximum size of a request in bytes. Note that Kafka broker can also cap the record batch size. |
simpleconsumer_pool_size_max | integer | no | Maximum number of SimpleConsumers that can be instantiated per broker |
Last updated on