Ray

Fixes https://github.com/fluent/fluent-plugin-kafka/issues/462 Additionally, I just realised there's also a slight behavior change made in https://github.com/fluent/fluent-plugin-kafka/pull/454. Prior to that commit, we were fetching Kafka topic related metadata only for the given...

Addresses https://github.com/nodeshift/opossum/issues/673 This PR adds `AbortController` support in Opossum. This is useful in conjunction with the timeout feature, where Opossum will signal upon timeout and allow users to cleanly abort...

Hey team, This is a feature request to add support for `AbortController` - https://developer.mozilla.org/en-US/docs/Web/API/AbortController - https://nodejs.org/docs/latest-v15.x/api/globals.html#globals_class_abortcontroller With `AbortController`, Opossum should be able to send signal to the underlying method to...

fix(out_rdkafka2): fix compatibility with rdkafka 0.12.0

3

Fixes https://github.com/fluent/fluent-plugin-kafka/issues/463 I think this is the simplest implementation that I could find to support rdkafka 0.12.0, but unfortunately because of how we're monkey patching the methods, it means we'd...

…to 0.12.0 Signed-off-by: Ray Tung

Lowering log level of "chunk bytes limit exceeds for an emitted event stream" logs to trace

1

### Is your feature request related to a problem? Please describe. Hey team 👋 From what I have gathered, fluentd did not split chunks if the event stream exceeds the...

fix(index, saved_searches): Refreshing Terraform state if resources are deleted outside of Terraform

4

Hey team, This PR fixes a problem with the index and saved_searches resource if someone deleted them outside of Terraform. Instead of erroring out on Terraform plan / apply, it...

feat(out_waterdrop): add basic waterdrop output plugin

3

This is a super simple proof-of-concept implementation for Waterdrop as described in https://github.com/fluent/fluent-plugin-kafka/issues/500. We'll need a lot more work to get this up to scratch compared to the other output...