flink-http-connector
flink-http-connector copied to clipboard
getindata
Http Connector for Apache Flink. Provides sources and sinks for Datastream , Table and SQL APIs.
#### Description `Add retry logic with delivery guarantees, retry all failed requests` Resolves `182` ##### PR Checklist - [x] Tests added - [x] [Changelog](CHANGELOG.md) updated
Currently the http sink and http lookup retry, error, and ignore codes are parsed differently and have different variables. It may be helpful to consolidate on the http lookup behavior,...
Currently the Http Sink retry behavior is not implemented. Http retries are a common behavior that is sometimes necessary, especially in high throughput applications.
Have you considered the possibility of passing dynamic headers based on the values in the record? Perhaps something like the headers in Kafka SQL Connector - https://nightlies.apache.org/flink/flink-docs-master/docs/connectors/table/kafka/#available-metadata? ``` INSERT INTO...
#### Description Upgrade flink-http-connector to Flink 2.0. Resolves `HTTP-126` ##### PR Checklist - [ ] Tests added - [ ] [Changelog](CHANGELOG.md) updated
