Skip to content

Commit 2828bd9

Browse files
committed
Backport of fixes from more recent branches:
Fixed incorrect millisecond to second conversion for retry_backoff_ms #216 Fixed unnecessary sleep after exhausted retries #166 Changed Kafka send errors to log as warn #179
1 parent 6d3dd87 commit 2828bd9

File tree

3 files changed

+10
-2
lines changed

3 files changed

+10
-2
lines changed

.travis.yml

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -7,7 +7,9 @@ rvm:
77
- jruby-1.7.25
88
env:
99
- KAFKA_VERSION=0.10.0.1
10-
before_install: ./kafka_test_setup.sh
10+
before_install:
11+
- gem install bundler -v '< 2'
12+
- ./kafka_test_setup.sh
1113
before_script:
1214
- bundle exec rake vendor
1315
script: bundle exec rspec && bundle exec rspec --tag integration

CHANGELOG.md

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1,3 +1,9 @@
1+
## 5.1.12
2+
- Backport of fixes from more recent branches:
3+
- Fixed incorrect millisecond to second conversion for retry_backoff_ms [#216](https://github.com/logstash-plugins/logstash-output-kafka/pull/216)
4+
- Fixed unnecessary sleep after exhausted retries [#166](https://github.com/logstash-plugins/logstash-output-kafka/pull/166)
5+
- Changed Kafka send errors to log as warn [#179](https://github.com/logstash-plugins/logstash-output-kafka/pull/179)
6+
17
## 5.1.11
28
- Bugfix: Sends are now retried until successful. Previously, failed transmissions to Kafka
39
could have been lost by the KafkaProducer library. Now we verify transmission explicitly.

kafka_test_setup.sh

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -5,7 +5,7 @@ set -ex
55
if [ -n "${KAFKA_VERSION+1}" ]; then
66
echo "KAFKA_VERSION is $KAFKA_VERSION"
77
else
8-
KAFKA_VERSION=0.10.1.0
8+
KAFKA_VERSION=0.10.2.2
99
fi
1010

1111
echo "Downloading Kafka version $KAFKA_VERSION"

0 commit comments

Comments
 (0)