Skip to content

Commit

Permalink
add kafka request max size env variable
Browse files Browse the repository at this point in the history
  • Loading branch information
@mehrdadrad
mehrdadrad committed Jan 11, 2018
1 parent 76f552d commit ddb400f
Show file tree
Hide file tree
Showing 2 changed files with 12 additions and 12 deletions.
22 changes: 11 additions & 11 deletions docs/config.md
View file
Original file line number Diff line number Diff line change
Expand Up @@ -80,17 +80,17 @@ The default configuration file is /etc/vflow/mq.conf, you can be able to change
## Configuration Keys
The Kafka configuration contains the following key

|Key | Default | Environment variable | Description |
|---------------------| ------------|--------------------------|------------------------------------------------------------------------------------|
|brokers | - | VFLOW_KAFKA_BROKERS | kafka broker addresses |
|compression | none | VFLOW_KAFKA_COMPRESSION | compression codecs: gzip, snappy, lz4 |
|retry-max | 2 | VFLOW_KAFKA_RETRY_MAX | the total number of times to retry |
|request-size-max | 104857600 | NA | the maximum size (in bytes) of any request that will be attempted to send to Kafka |
|retry-backoff | 10 | VFLOW_KAFKA_RETRY_BACKOFF| wait for leader election to occur before retrying in milliseconds |
|tls-cert | none | VFLOW_KAFKA_TLS_CERT | certificate file for client authentication |
|tls-key | none | VFLOW_KAFKA_TLS_KEY | key file for client authentication |
|ca-file | none | VFLOW_KAFKA_CA_FILE | certificate authority file for TLS client authentication |
|verify-ssl | true | VFLOW_KAFKA_VERIFY_SSL | verify ssl certificates chain |
|Key | Default | Environment variable | Description |
|---------------------| ------------|------------------------------|------------------------------------------------------------------------------------|
|brokers | - | VFLOW_KAFKA_BROKERS | kafka broker addresses |
|compression | none | VFLOW_KAFKA_COMPRESSION | compression codecs: gzip, snappy, lz4 |
|retry-max | 2 | VFLOW_KAFKA_RETRY_MAX | the total number of times to retry |
|request-size-max | 104857600 | VFLOW_KAFKA_REQUEST_SIZE_MAX | the maximum size (in bytes) of any request that will be attempted to send to Kafka |
|retry-backoff | 10 | VFLOW_KAFKA_RETRY_BACKOFF | wait for leader election to occur before retrying in milliseconds |
|tls-cert | none | VFLOW_KAFKA_TLS_CERT | certificate file for client authentication |
|tls-key | none | VFLOW_KAFKA_TLS_KEY | key file for client authentication |
|ca-file | none | VFLOW_KAFKA_CA_FILE | certificate authority file for TLS client authentication |
|verify-ssl | true | VFLOW_KAFKA_VERIFY_SSL | verify ssl certificates chain |

## Example
```
Expand Down
2 changes: 1 addition & 1 deletion producer/kafka.go
View file
Original file line number Diff line number Diff line change
Expand Up @@ -49,7 +49,7 @@ type KafkaConfig struct {
Brokers []string `yaml:"brokers" env:"BROKERS"`
Compression string `yaml:"compression" env:"COMPRESSION"`
RetryMax int `yaml:"retry-max" env:"RETRY_MAX"`
RequestSizeMax int32 `yaml:"request-size-max" env:"NA"`
RequestSizeMax int32 `yaml:"request-size-max" env:"REQUEST_SIZE_MAX"`
RetryBackoff int `yaml:"retry-backoff" env:"RETRY_BACKOFF"`
TLSCertFile string `yaml:"tls-cert" env:"TLS_CERT"`
TLSKeyFile string `yaml:"tls-key" env:"TLS_KEY"`
Expand Down

0 comments on commit ddb400f

Please sign in to comment.