keda-connectors

keda-connectors copied to clipboard

NATS Jetstream MQT goes in a loop if function returns code other than 200

1

**Fission/Kubernetes version** Fission version 1.17 / Kubernetes version 1.24 $ fission --version client: fission/core: BuildDate: "2022-09-16T13:24:57Z" GitCommit: b36e0516 Version: v1.17.0 server: fission/core: BuildDate: "2022-09-16T13:24:57Z" GitCommit: b36e0516 Version: v1.17.0 $ kubectl...

umeshgtank

I created pull consumer but getting following error: {"level":"fatal","ts":1677184769.1167047,"caller":"app/main.go:63","msg":"error occurred while parsing metadata","error":"nats: must use pull subscribe to bind to pull based consumer","stacktrace":" │ │ main.main\n\t/app/main.go:63\nruntime.main\n\t/usr/local/go/src/runtime/proc.go:250"} **Fission/Kubernetes version** $ fission...

yaymarius

Add response code to common http_client

3

This PR modified the HTTP client so that: * It returns the HTTP code for the request * If the response body exists, it is returned. If the request itself...

ranoble

Adds support for Kafka Keys, and handles nil for both keys and values…

2

… as kafka would expect Keys are passed as a header: `KEDA-Message-Key`. If no key exists, no header will be sent (to avoid the nil == '' problem). If a...

ranoble

[Bug] Duplicated content type in header when use kafka-http-connector

1

Hi there, I found an issue in kafka-http-connector. https://github.com/fission/keda-connectors/blob/da094250dc08122358a725cf67d54cf5fc313396/kafka-http-connector/main.go#L215-L226 If the message header also specifies the same keys (ex: content-type), when it sends the request to the function might be...

chenjr0719

Using fission ``` client: fission/core: BuildDate: "2020-10-20T14:43:45Z" GitCommit: 52508e19343ef93da4ce8960908c5569f44da225 Version: 1.11.2 server: fission/core: BuildDate: "2020-10-20T14:43:45Z" GitCommit: 52508e19343ef93da4ce8960908c5569f44da225 Version: 1.11.2 ``` with keda ``` mqt_keda: enabled: true connector_images: kafka: image: fission/keda-kafka-http-connector...

danyc

Kafka connector should support offset . User function might want to process all the messages from 1. Beginning of a topic 2. From a particular value 3. From the latest...

RealHarshThakur

Integration test for connectors

1

A generic integration test framework for Keda connectors which can simulate: 1. Create a Kind cluster 2. Deploy the respective MQ (For PR - detect changes to specific connector dynamically)...

vishal-biyani

AWS Kinesis Stream Http Connector

3

CCL https://github.com/fission/fission/issues/1663

vishal-biyani

Azure Storage Queue Http connector

2

CC: https://github.com/fission/fission/issues/1663

vishal-biyani