Commit Graph

57 Commits

Author SHA1 Message Date
Paweł Żak 0a6e51d1d6
chore: Fix linter findings for `revive:enforce-slice-style` in `plugins/inputs/[k-o]*` (#16071) 2024-10-28 14:30:13 +01:00
Paweł Żak b029889212
chore(linters): Fix findings found by `testifylint`: `go-require` for `plugins/common` and `plugins/inputs` (#15991) 2024-10-08 15:55:27 -05:00
Paweł Żak 40d7961e31
test(compilation): Fixing test compilation (#15978) 2024-10-03 15:45:09 -05:00
Sven Rebhan cb571deb41
feat(inputs.kafka_consumer): Implement startup error behavior options (#15919) 2024-10-03 11:41:20 -05: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
Paweł Żak 453d32bd81
chore: Fix linter findings for `revive:comment-spacings` (part 2) (#15897) 2024-09-19 11:03:28 +02: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 9e3e22094a
feat(inputs.kafka_consumer): Allow to select the metric time source (#15790) 2024-08-30 14:18:04 -05:00
Sven Rebhan d160276552
feat(logging): Add 'trace' log-level (#15695) 2024-08-01 00:32:24 +02:00
dependabot[bot] a978110b2c
chore(deps): Bump github.com/docker/docker from 25.0.5+incompatible to 27.1.1+incompatible (#15681) 2024-07-31 10:54:08 -05:00
Dane Strandboge 19737fcb52
chore(linters): Fix remaining errcheck warnings (#15518)
Co-authored-by: Joshua Powers <powersj@fastmail.com>
2024-07-10 12:51:25 +02:00
Joshua Powers 65d106f615
chore(deps): Point kafka dependency to IBM organization (#14349) 2023-11-27 17:13:22 +01:00
Joshua Powers 4c4b821aaa
test(kafka): Use dynamic ports with integration tests (#14301) 2023-11-17 10:47:18 +01:00
Paweł Żak 8fbea28ab3
chore(linters): Fix findings found by testifylint: expected-actual (#14229) 2023-11-01 14:09:55 -06:00
Adam Thornton 38b8a1bcde
fix(parsers.json_v2): Prevent race condition in parse function (#14149) 2023-10-30 09:04:41 +01:00
Tobias Jungel 3fae6439ab
fix(inputs.kafka_consumer): Use per-message parser to avoid races (#13886) 2023-09-11 08:18:51 -06:00
Joshua Powers 9f83bee8ef
Revert "feat(inputs.kafka_consumer): Refresh regexp topics periodically (#13410)" (#13617)
This reverts commit a13f3463eb.
2023-07-14 16:06:45 +02:00
Adam Thornton a13f3463eb
feat(inputs.kafka_consumer): Refresh regexp topics periodically (#13410) 2023-07-07 10:45:37 -06:00
Adam Thornton 8762c71e65
feat(inputs.kafka_consumer): Add regular expression support for topics (#11831) 2023-05-23 12:08:01 -06:00
Sven Rebhan 9bb2d1562d
chore(serializers): Add new-style framework and migrate influx (#12920) 2023-04-11 21:52:42 +02:00
Joshua Powers 3415cc8c80
chore: Fix gosec G102 issues (#12923) 2023-03-28 11:40:29 +02:00
Paweł Żak 6816aefcd5
chore: fix linter findings for unparam and revive.unused-parameter (#12150) 2022-11-08 12:04:12 -07: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
Paweł Żak e2b999267f
chore: Fix linter findings introduced in last PRs (#12131) 2022-11-01 11:27:37 +01:00
reimda 3196bc4c1c
chore: shut down plugins gracefully to prevent race (#12102) 2022-10-26 09:32:58 -06:00
reimda d88067566c
chore: skip integration test with race (#12100) 2022-10-25 09:41:46 -06:00
reimda 7d9f09ddc8
chore: add kafka round trip integration test using inputs.kafka_consumer and outputs.kafka (#12058) 2022-10-25 07:50:59 -06:00
Joshua Blanchard 2b03cd9151
fix(common.kafka): Enable TLS in Kafka plugins without custom config (#11519) 2022-09-26 12:14:14 -06:00
Sven Rebhan e2578462a5
fix(inputs): Linter issues (#11576) 2022-08-02 13:52:17 +02:00
Joshua Powers b423a3ec40
feat: migrate value parser to new style (#11407) 2022-06-29 14:46:43 -06:00
Paweł Żak c875e45422
fix: Linter fixes for plugins/inputs/[a-o]* (leftovers) (#10192)
Co-authored-by: Pawel Zak <Pawel Zak>
2021-11-30 15:59:24 -06:00
Chris Ruscio 343e846480
feat: add max_processing_time config to Kafka Consumer input (#9988) 2021-10-28 14:35:22 -06:00
Paweł Żak eec6fd5702
fix: Linter fixes for plugins/inputs/[k-l]* (#9999) 2021-10-27 09:48:57 -06:00
Sven Rebhan 8e7da355b3
Linter fixes (unhandled errors) -- Part 1 (#8992) 2021-04-08 11:43:39 -05:00
Paweł Żak 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
David Bennett c905116ade
Add 'field name' config option to customize field name when using Value parser. (#8979) 2021-03-11 21:53:32 -05:00
Steven Soroka 8b30bb9534
Enable kafka zstd compression and idempotent writes (#8435) 2020-11-23 15:51:58 -05:00
reimda 5a5f6fbd47
Update sarama library to 1.27.1 (#8289) 2020-10-20 11:42:37 -04:00
Daniel Nelson c73ed8ca6c
Export internal/tls package for use in execd plugins (#7697) 2020-06-25 11:44:22 -07:00
Daniel Nelson c06eef47e7
Fix data race in kafka_consumer_test.go (#7737) 2020-06-24 15:21:56 -07:00
Daniel Nelson 2486006495
Add kafka SASL version control to kafka_consumer (#6350) 2020-01-02 16:27:26 -08:00
Daniel Nelson aea09b3a20
Use sarama built in support for consumer groups (#6172) 2019-07-29 20:41:12 -07:00
Sebastien Le Digabel 448c98d82e Add ability to tag metrics with topic in kafka_consumer (#5038) 2018-11-28 16:29:26 -08:00
Daniel Nelson 6e5c2f8bb6
Remove outputs blocking inputs when output is slow (#4938) 2018-11-05 13:34:28 -08:00
maxunt 2729378b7f Add name, time, path and string field options to JSON parser (#4351) 2018-08-22 19:26:48 -07:00
Seuf 2092443cd7 Add Kafka 0.9+ consumer support (#2487) 2017-06-07 18:22:28 -07:00
Patrick Hemmer 06baf7cf78 use AddError everywhere (#2372) 2017-04-24 11:13:26 -07:00
Nick Irvine 0193cbee51 Add max_message_len in kafka_consumer input (#2636) 2017-04-11 12:05:39 -07:00
Patrick Hemmer 1402c158b7 remove sleep from tests (#2555) 2017-03-24 12:03:36 -07:00
Emil Haugbergsmyr 81f95e7a29 Fixes change in Kafka consumer input plugin (#2222)
* Fixes change to the error api in the kafka project.

* Updated test to reflect the change.

* Update kafka to match master branch.
2017-01-11 16:24:09 +00:00