forked from fluent/fluent-plugin-kafka
-
Notifications
You must be signed in to change notification settings - Fork 0
/
Copy pathChangeLog
151 lines (85 loc) · 3.62 KB
/
ChangeLog
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
Release 0.7.8 - 2018/08/29
* input: Fix regression of kafka initialization
Release 0.7.7 - 2018/08/27
* in_kafka_group: Add retry_limit and disable_retry_limit parameters
* input: Support SSL parameters
* Add ssl_ca_certs_from_system parameter
* Make password parameter secret
Release 0.7.6 - 2018/08/15
* out_kafka2: Add ignore_exceptions and exception_backup parameters
Release 0.7.5 - 2018/08/14
* out_kafka2: Fix `message_key_key` parameter handling
* Limit ruby-kafka version('< 0.7.0') to avoid runtime error
Release 0.7.4 - 2018/07/11
* out_kafka2: Need event_emitter helper for notification
Release 0.7.3 - 2018/05/30
* output: Use SSL endpoint when ssl_client_cert is true
Release 0.7.2 - 2018/03/12
* output: Fix the regression of get_kafka_client_log parameter
Release 0.7.1 - 2018/03/05
* out_kafka2: Fix the regression of kafka client initialization
Release 0.7.0 - 2018/02/27
* output: SASL PLAIN/SCRAM support
* input: Fix TimeParser location bug in v1
* out_kafka2: Fix warning condition for tag chunk key
Release 0.6.6 - 2017/12/25
* output: Make topic/partition/partition_key/message_key configurable
Release 0.6.5 - 2017/12/14
* in_kafka_group: Add client_id parameter
Release 0.6.4 - 2017/11/23
* Multi worker support for v0.14
* Add kafka_message_key parameter to input plugins
* Relax ruby-kafka version for 0.5 or later
* Use oj for json when it is installed
Release 0.6.3 - 2017/11/14
* in_kafka_group: re-create consumer when error happens during event fetch
Release 0.6.2 - 2017/11/1
* Fix ltsv parsing issue which generates symbol keys
Release 0.6.1 - 2017/08/30
* Add stats and datadog monitoring support
* ssl_ca_certs now accepts multiple paths
* Fix bug by ruby-kafka 0.4.1 changes
* Update ruby-kafka dependency to v0.4.1
Release 0.6.0 - 2017/07/25
* Add principal and keytab parameters for SASL support
Release 0.5.7 - 2017/07/13
* out_kafka_buffered: Add kafka_agg_max_messages parameter
Release 0.5.6 - 2017/07/10
* output: Add ActiveSupport notification support
Release 0.5.5 - 2017/04/19
* output: Some trace log level changed to debug
* out_kafka_buffered: Add discard_kafka_delivery_failed parameter
Release 0.5.4 - 2017/04/12
* out_kafka_buffered: Add max_send_limit_bytes parameter
* out_kafka: Improve buffer overflow handling of ruby-kafka
Release 0.5.3 - 2017/02/13
* Relax ruby-kafka dependency
Release 0.5.2 - 2017/02/13
* in_kafka_group: Add max_bytes parameter
Release 0.5.1 - 2017/02/06
* in_kafka_group: Fix uninitialized constant error
Release 0.5.0 - 2017/01/17
* output: Add out_kafka2 plugin with v0.14 API
Release 0.4.2 - 2016/12/10
* input: Add use_record_time and time_format parameters
* Update ruby-kafka dependency to 0.3.16.beta2
Release 0.4.1 - 2016/12/01
* output: Support specifying partition
Release 0.4.0 - 2016/11/08
* Remove zookeeper dependency
Release 0.3.5 - 2016/10/21
* output: Support message key and related parameters. #91
Release 0.3.4 - 2016/10/20
* output: Add exclude_topic_key and exclude_partition_key. #89
Release 0.3.3 - 2016/10/17
* out_kafka_buffered: Add get_kafka_client_log parameter. #83
* out_kafka_buffered: Skip and log invalid record to avoid buffer stuck. #86
* in_kafka_group: Add retry_emit_limit to handle BufferQueueLimitError. #87
Release 0.3.2 - 2016/10/06
* in_kafka_group: Re-fetch events after consumer error. #79
Release 0.3.1 - 2016/08/28
* output: Change default required_acks to -1. #70
* Support ruby version changed to 2.1.0 or later
Release 0.3.0 - 2016/08/24
* Fully replace poseidon ruby library with ruby-kafka to support latest kafka versions
See git commits for older changes