Skip to content
This repository was archived by the owner on Dec 1, 2018. It is now read-only.

Commit 908cf7b

Browse files
committed
revert to kafka.CompressionNone && add dot after each lines
1 parent 777b799 commit 908cf7b

File tree

2 files changed

+5
-5
lines changed

2 files changed

+5
-5
lines changed

common/kafka/kafka.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -116,7 +116,7 @@ func getCompression(opts url.Values) (kafka.CompressionCodec, error) {
116116
case "lz4":
117117
return kafka.CompressionLZ4, nil
118118
default:
119-
return -1, fmt.Errorf("Compression '%s' is illegal. Use none, snappy, lz4 or gzip", comp)
119+
return kafka.CompressionNone, fmt.Errorf("Compression '%s' is illegal. Use none, snappy, lz4 or gzip", comp)
120120
}
121121
}
122122

docs/sink-configuration.md

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -191,15 +191,15 @@ So, we provide kafka brokers' list and topics about timeseries & topic in url's
191191
Options can be set in query string, like this:
192192

193193
* `brokers` - Kafka's brokers' list.
194-
* `timeseriestopic` - Kafka's topic for timeseries. Default value : `heapster-metrics`
195-
* `eventstopic` - Kafka's topic for events. Default value : `heapster-events`
196-
* `compression` - Kafka's compression for both topics. Must be `gzip` or `none` or `snappy` or `lz4`. Default value : none
194+
* `timeseriestopic` - Kafka's topic for timeseries. Default value : `heapster-metrics`.
195+
* `eventstopic` - Kafka's topic for events. Default value : `heapster-events`.
196+
* `compression` - Kafka's compression for both topics. Must be `gzip` or `none` or `snappy` or `lz4`. Default value : none.
197197
* `user` - Kafka's SASL PLAIN username. Must be set with `password` option.
198198
* `password` - Kafka's SASL PLAIN password. Must be set with `user` option.
199199
* `cacert` - Kafka's SSL Certificate Authority file path.
200200
* `cert` - Kafka's SSL Client Certificate file path (In case of Two-way SSL). Must be set with `key` option.
201201
* `key` - Kafka's SSL Client Private Key file path (In case of Two-way SSL). Must be set with `cert` option.
202-
* `insecuressl` - Kafka's Ignore SSL certificate validity. Default value : `false`
202+
* `insecuressl` - Kafka's Ignore SSL certificate validity. Default value : `false`.
203203

204204
For example,
205205

0 commit comments

Comments
 (0)