Skip to content

Commit 15219a1

Browse files
strawgatejsvd
andauthored
Add default client_id of logstash to kafka output (#169)
--------- Co-authored-by: João Duarte <[email protected]>
1 parent fbd6e20 commit 15219a1

File tree

4 files changed

+6
-3
lines changed

4 files changed

+6
-3
lines changed

CHANGELOG.md

+3
Original file line numberDiff line numberDiff line change
@@ -1,3 +1,6 @@
1+
## 11.4.2
2+
- Add default client_id of logstash to kafka output [#169](https://github.com/logstash-plugins/logstash-integration-kafka/pull/169)
3+
14
## 11.4.1
25
- [DOC] Match anchor ID and references for `message_headers` [#164](https://github.com/logstash-plugins/logstash-integration-kafka/pull/164)
36

docs/output-kafka.asciidoc

+1-1
Original file line numberDiff line numberDiff line change
@@ -192,7 +192,7 @@ If not explicitly configured it defaults to `use_all_dns_ips`.
192192
===== `client_id`
193193

194194
* Value type is <<string,string>>
195-
* There is no default value for this setting.
195+
* Default value is `"logstash"`
196196

197197
The id string to pass to the server when making requests.
198198
The purpose of this is to be able to track the source of requests beyond just

lib/logstash/outputs/kafka.rb

+1-1
Original file line numberDiff line numberDiff line change
@@ -91,7 +91,7 @@ class LogStash::Outputs::Kafka < LogStash::Outputs::Base
9191
# The id string to pass to the server when making requests.
9292
# The purpose of this is to be able to track the source of requests beyond just
9393
# ip/port by allowing a logical application name to be included with the request
94-
config :client_id, :validate => :string
94+
config :client_id, :validate => :string, :default => "logstash"
9595
# Serializer class for the key of the message
9696
config :key_serializer, :validate => :string, :default => 'org.apache.kafka.common.serialization.StringSerializer'
9797
# The producer groups together any records that arrive in between request

logstash-integration-kafka.gemspec

+1-1
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,6 @@
11
Gem::Specification.new do |s|
22
s.name = 'logstash-integration-kafka'
3-
s.version = '11.4.1'
3+
s.version = '11.4.2'
44
s.licenses = ['Apache-2.0']
55
s.summary = "Integration with Kafka - input and output plugins"
66
s.description = "This gem is a Logstash plugin required to be installed on top of the Logstash core pipeline "+

0 commit comments

Comments
 (0)