[jira] [Commented] (FLINK-9544) Downgrade kinesis protocol from CBOR to JSON not possible as required by kinesalite

[ https://issues.apache.org/jira/browse/FLINK-9544?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16650340#comment-16650340 ] Ph.Duveau commented on FLINK-9544: -- Bonjour, Je suis absent et serai de retour le lundi 05 novembre.

[jira] [Updated] (FLINK-9544) Downgrade kinesis protocol from CBOR to JSON not possible as required by kinesalite

[ https://issues.apache.org/jira/browse/FLINK-9544?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ph.Duveau updated FLINK-9544: - Summary: Downgrade kinesis protocol from CBOR to JSON not possible as required by kinesalite (was:

[jira] [Updated] (FLINK-9544) Downgrade kinesis protocole from CBOR to JSON not possible as required by kinesalite

[ https://issues.apache.org/jira/browse/FLINK-9544?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ph.Duveau updated FLINK-9544: - Summary: Downgrade kinesis protocole from CBOR to JSON not possible as required by kinesalite (was:

[jira] [Updated] (FLINK-9544) Impossible to downgrade kinesis protocole from CBOR to JSON as required by kinesalite

[ https://issues.apache.org/jira/browse/FLINK-9544?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ph.Duveau updated FLINK-9544: - Description: The amazon client do not downgrade from CBOR to JSON while setting env AWS_CBOR_DISABLE to

[jira] [Created] (FLINK-9544) Impossible to downgrade kinesis protocole from CBOR to JSON as required by kinesalite

Ph.Duveau created FLINK-9544: Summary: Impossible to downgrade kinesis protocole from CBOR to JSON as required by kinesalite Key: FLINK-9544 URL: https://issues.apache.org/jira/browse/FLINK-9544 Project:

[jira] [Updated] (FLINK-8556) Add proxy feature to Kinesis Connector to acces its endpoint

[ https://issues.apache.org/jira/browse/FLINK-8556?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ph.Duveau updated FLINK-8556: - Summary: Add proxy feature to Kinesis Connector to acces its endpoint (was: Add proxy usage to Kinesis

[jira] [Created] (FLINK-8556) Add proxy usage to Kinesis Connector to acces its endpoint

Ph.Duveau created FLINK-8556: Summary: Add proxy usage to Kinesis Connector to acces its endpoint Key: FLINK-8556 URL: https://issues.apache.org/jira/browse/FLINK-8556 Project: Flink Issue Type:

[jira] [Commented] (FLINK-8468) Make the connector to take advantage of AMQP features (routing key, exchange and message properties)

[ https://issues.apache.org/jira/browse/FLINK-8468?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16351580#comment-16351580 ] Ph.Duveau commented on FLINK-8468: -- Also added the ability to disable queue creation on setup > Make the

[jira] [Updated] (FLINK-8468) Make the connector to take advantage of AMQP features (routing key, exchange and message properties)

[ https://issues.apache.org/jira/browse/FLINK-8468?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ph.Duveau updated FLINK-8468: - Description: Make the connector to take advantage of AMQP features by adding a constructor and an

[jira] [Updated] (FLINK-8468) Allow the sink to be extended

[ https://issues.apache.org/jira/browse/FLINK-8468?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ph.Duveau updated FLINK-8468: - Description: We extend RMQSink to get a variable routingkey using fields from the "value" and also to

[jira] [Created] (FLINK-8468) Allow the sink to be extended

Ph.Duveau created FLINK-8468: Summary: Allow the sink to be extended Key: FLINK-8468 URL: https://issues.apache.org/jira/browse/FLINK-8468 Project: Flink Issue Type: Improvement