Details
-
Sub-task
-
Status: Resolved
-
Major
-
Resolution: Fixed
-
1.1.0
-
None
Description
Currently, the Kinesis consumer and producer are configured differently.
The producer expects a list of arguments for the access key, secret, region, stream. The consumer is accepting properties (similar to the Kafka connector).
The objective of this issue is to change the producer so that it is also using a properties-based configuration (including an input validation step)
Attachments
Issue Links
- links to