Commit Graph

31 Commits

Author SHA1 Message Date
Sven Rebhan 403199fb46
feat(common.kafka): Add AWS-MSK-IAM SASL authentication (#16524) 2025-04-23 09:34:16 -05:00
Paulo Dias cb71790cf7
chore(linters): Enforce import grouping with gci linter (#16526)
Signed-off-by: Paulo Dias <paulodias.gm@gmail.com>
Co-authored-by: Thomas Casteleyn <thomas.casteleyn@me.com>
2025-02-24 19:37:12 -06:00
Paweł Żak d26479b58e
chore: Fix linter findings for `revive:unused-receiver` in `plugins/`: `aggregators`, `common`, `parsers`, `processors`, `secretstores` and `serializers` (#16339) 2025-01-14 09:24:13 +01:00
Paweł Żak 9415d8e7e9
chore(linters): Enable `import-alias-naming` and `redundant-import-alias` rules for revive (#15836) 2024-10-01 13:49:53 -05:00
Sven Rebhan b2967cb515
chore: Update go to v1.23.0 (#15766)
Co-authored-by: Pawel Zak <pawel.zak.pawel@gmail.com>
2024-08-30 14:23:51 -05:00
Sven Rebhan d160276552
feat(logging): Add 'trace' log-level (#15695) 2024-08-01 00:32:24 +02:00
Sven Rebhan ef41198481
chore(logging): Implement early logging (#15629) 2024-07-26 09:09:21 -06:00
Viktor Szépe 31a1d34d99
chore: Fix typos throughout codebase (#15338) 2024-05-31 10:26:37 +02:00
Sven Rebhan 71b58ddaf5
chore(log): Restructure and cleanup logging code (#15234) 2024-05-10 16:43:43 -05:00
Paweł Żak c4dbe65732
chore(linters): Bump golangci-lint to v1.56.1 (#14759) 2024-02-12 23:26:10 +01:00
Paweł Żak ae7fbc5082
chore(linters): Replace 'fmt.Errorf' with 'errors.New' wherever possible (#14698) 2024-02-08 11:32:30 -06:00
Joshua Powers 12095b2828
fix(common.kafka): Correctly set gssapi username/password (#14522) 2024-01-05 10:57:52 +01:00
Joshua Powers 65d106f615
chore(deps): Point kafka dependency to IBM organization (#14349) 2023-11-27 17:13:22 +01:00
Sven Rebhan e2c4e10650
chore(secrets): Abstract secret implementation (#13953) 2023-09-25 14:37:04 -06:00
Joshua Powers d4235ab86b
feat(kafka): Set and send SASL extensions (#13411) 2023-07-14 09:23:59 -06:00
Joshua Powers 1b8339ace8
docs(common.kafka): Remove experimental notes (#13232) 2023-05-04 19:17:40 +02:00
Sven Rebhan 83b4056985
fix(secrets): Minimize secret holding time (#13002) 2023-04-03 07:28:41 -06:00
Sven Rebhan 63ab159481
feat(secretstores): add support for additional input plugins (#12067) 2023-01-09 09:17:23 -07:00
Sven Rebhan 6fb08bb3da
feat(kafka): Add keep-alive period setting for input and output. (#12459) 2023-01-05 16:48:31 +01:00
Trevor North 70b33c2649
feat(inputs.kafka_consumer): Add sarama debug logs (#12304) 2022-12-05 21:54:08 +01:00
reimda 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
Joshua Blanchard 2b03cd9151
fix(common.kafka): Enable TLS in Kafka plugins without custom config (#11519) 2022-09-26 12:14:14 -06:00
Thomas Casteleyn a4f6b27bd5
style: Add deprecation notices to plugin options (#10616) 2022-03-01 15:05:53 -07:00
Paweł Żak 3627961add
fix: Linter fixes for plugins/common/[a-z]* (#10189)
Co-authored-by: Pawel Zak <Pawel Zak>
2021-11-30 15:46:46 -06:00
Gerald Quintana 8265969f52
feat: Kafka Add metadata full to config (#9833) 2021-10-21 15:32:39 -06:00
Paweł Żak 38c61c07ef
Revive fixes - part 4: (#8981)
empty-lines

Co-authored-by: Pawel Zak <Pawel Zak>
2021-03-12 14:21:51 -06:00
Helen Weller 372004a993
Fix max open requests to one if idempotent writes is set to true (#8954) 2021-03-08 11:38:35 -05:00
Paweł Żak d9736d543f
Revive fixes - part 2 (#8835)
* Revive fixes regarding following set of rules:
[rule.if-return]
[rule.increment-decrement]
[rule.var-declaration]
[rule.package-comments]
[rule.receiver-naming]
[rule.unexported-return]
2021-02-16 18:19:50 -05:00
Steven Soroka 8b30bb9534
Enable kafka zstd compression and idempotent writes (#8435) 2020-11-23 15:51:58 -05:00
Steven Soroka e83a165635
kafka sasl-mechanism auth support for SCRAM-SHA-256, SCRAM-SHA-512, GSSAPI (#8318) 2020-10-28 12:16:59 -04:00
Daniel Nelson 2486006495
Add kafka SASL version control to kafka_consumer (#6350) 2020-01-02 16:27:26 -08:00