062326eb48
test(outputs.kafka): Rework integration test to use bitnami/kafka ( #14161 )
2023-10-23 10:44:17 -06:00
fd773b3e28
fix(outputs.kafka): Simplify send-error handling ( #14154 )
2023-10-23 07:51:57 -06:00
39d6b1d5cb
chore: Fix linter findings for errorlint (part3) ( #12704 )
...
Co-authored-by: Pawel Zak <Pawel Zak>
2023-02-22 13:38:16 +01:00
0244614b71
chore(deps): Bump github.com/gofrs/uuid from 4.3.1+incompatible to 5.0.0 ( #12668 )
2023-02-16 10:50:47 +01:00
70b33c2649
feat(inputs.kafka_consumer): Add sarama debug logs ( #12304 )
2022-12-05 21:54:08 +01:00
8e9a513157
chore: Wrap long lines in plugins/outputs ( #12179 )
2022-11-08 16:05:55 +01:00
0955bd714f
chore: Enable asciicheck, asasalint, bidichk and exportloopref linters ( #12169 )
2022-11-07 11:07:10 +01:00
494f558b4e
feat: Add exponential backoff when connecting or reconnecting and allow plugin to start without making initial connection ( #12111 )
2022-11-03 08:01:22 -05:00
d67f75e557
docs: Remove warning not to remove go:embed ( #11797 )
...
Co-authored-by: Joshua Powers <powersj@fastmail.com>
2022-09-13 12:47:58 -05:00
8c49ddccc3
chore: update to go1.19.1 ( #11776 )
2022-09-08 12:49:36 -06:00
ac26d786fe
fix(outputs): Linter issues ( #11595 )
2022-08-03 07:20:51 -05:00
2fc19fa308
chore: correctly spell embed ( #11200 )
2022-05-27 07:13:47 -06:00
d9a6d8b774
chore: embed sample configurations into README for outputs ( #11182 )
2022-05-25 08:48:59 -06:00
a7df6c6aa6
feat: migrate output plugins to new sample config format ( #10910 )
2022-04-07 15:55:03 -06:00
0d529d89ea
feat: add socks5 proxy support for kafka output plugin ( #8192 )
2022-02-16 08:33:03 -07:00
020b77b239
fix: Linter fixes for plugins/outputs/[g-m]* ( #10127 )
...
Co-authored-by: Pawel Zak <Pawel Zak>
2021-11-24 12:40:25 -07:00
8265969f52
feat: Kafka Add metadata full to config ( #9833 )
2021-10-21 15:32:39 -06:00
565336280a
moved samara config out of init into connect ( #9051 )
2021-03-25 18:06:03 -04:00
74a1acd814
Linter fixes - revive:unused-parameter, unparam, varcheck and unused ( #8984 )
...
* Linter fixes - revive:unused-parameter and unparam
* Linter fixes - revive:unused-parameter and unparam
* Linter fixes - revive:unused-parameter and unparam
* "nolint"'s removed
* Fixes for "varcheck" and "unused" added.
* Fixes for "varcheck" and "unused" added.
* Fixes for "varcheck" and "unused" added.
* Fixes for "varcheck" and "unused" added.
* Fixes for "varcheck" and "unused" added.
* Fixes for "varcheck" and "unused" added.
* Fixes for "varcheck" and "unused" added.
Co-authored-by: Pawel Zak <Pawel Zak>
2021-03-22 12:21:36 -05:00
38c61c07ef
Revive fixes - part 4: ( #8981 )
...
empty-lines
Co-authored-by: Pawel Zak <Pawel Zak>
2021-03-12 14:21:51 -06:00
8b30bb9534
Enable kafka zstd compression and idempotent writes ( #8435 )
2020-11-23 15:51:58 -05:00
e83a165635
kafka sasl-mechanism auth support for SCRAM-SHA-256, SCRAM-SHA-512, GSSAPI ( #8318 )
2020-10-28 12:16:59 -04:00
c8e69aca3c
Fixed almost all bugs found by LGTM analysis platform ( #8240 )
2020-10-08 11:20:35 -04:00
c73ed8ca6c
Export internal/tls package for use in execd plugins ( #7697 )
2020-06-25 11:44:22 -07:00
b6de4da41f
Add topic tag options to kafka output ( #7142 )
2020-03-10 13:38:26 -07:00
0cc71dbd51
Document the behavior of an unset routing key ( #6983 )
2020-02-04 16:40:00 -08:00
f6b302621e
Do not add invalid timestamps to kafka messages ( #6908 )
2020-01-15 15:26:50 -08:00
2486006495
Add kafka SASL version control to kafka_consumer ( #6350 )
2020-01-02 16:27:26 -08:00
317c823bfc
Set message timestamp to the metric time in kafka output ( #6746 )
2019-12-03 11:48:53 -08:00
6cbaf890d9
Use github.com/gofrs/uuid 2.1.0 ( #6636 )
2019-11-07 17:39:19 -08:00
c9107015b0
Emit sarama library log messages at debug level ( #6091 )
2019-07-11 13:50:12 -07:00
4197426a73
Ignore errors serializing single metrics ( #5943 )
2019-06-03 17:34:48 -07:00
d2cf9a7157
Add support for static and random routing keys in kafka output ( #4579 )
2018-08-21 12:44:10 -07:00
886d8cc840
Drop message batches in kafka output if too large ( #4565 )
2018-08-17 13:51:21 -07:00
34614582a7
Use snake case in kafka output config
2018-08-15 14:12:22 -07:00
61513c64b8
Add message 'max_bytes' configuration ( #4537 )
2018-08-15 14:05:26 -07:00
f4032fc78d
Add support for lz4 compression to kafka output ( #4492 )
2018-07-31 16:09:30 -06:00
943dcc0c49
Send all messages before waiting for results in kafka output ( #4491 )
2018-07-31 16:08:04 -06:00
49a5dea536
Update client_id in kafka input and output readme
2018-07-13 14:00:25 -07:00
c8f00030dd
Add support for setting kafka client id ( #4418 )
2018-07-13 13:53:56 -07:00
de355b76d6
Simplify testing with TLS ( #4095 )
2018-05-04 16:33:23 -07:00
2108582b43
Clarify max_retry option in kafka output
2018-05-03 17:22:49 -07:00
402a0f16e1
Fix typo
2017-09-06 14:19:42 -07:00
5d4eec606f
Add Kafka output plugin topic_suffix option ( #3196 )
2017-09-06 14:18:26 -07:00
cd103c85db
Added SASL options for ouput kafka plugin ( #2721 )
2017-04-27 11:50:25 -07:00
cb9aecbf04
it's -> its ( #2729 )
2017-04-27 11:06:40 -07:00
285be648c4
Godeps update
...
closes #2356
2017-02-02 09:52:06 +00:00
a093ec1eaa
Kafka output fixup
2016-12-06 15:38:59 +00:00
a30b1a394f
Kafka output: set max_retry=3 & required_acks=-1 as defaults
...
closes #1113
2016-04-29 18:51:45 -06:00
e436b2d720
Cleanup & standardize config file
...
changes:
- -sample-config will now comment out all but a few default plugins.
- config file parse errors will output path to bad conf file.
- cleanup 80-char line-length and some other style issues.
- default package conf file will now have all plugins, but commented
out.
closes #199
closes #944
2016-04-01 10:59:53 -06:00
Sven Rebhan
Paweł Żak
dependabot[bot]
Trevor North
reimda
Sebastian Spaink
Joshua Powers
Alexander Olekhnovich
Gerald Quintana
Helen Weller
Steven Soroka
Daniel Nelson
Daniel Nelson
Mauro Murari
Rion
Pavel Gurkov
Seuf
Damien Krotkine
Cameron Sparr