[ https://issues.apache.org/jira/browse/FLINK-3230?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15247511#comment-15247511 ]
ASF GitHub Bot commented on FLINK-3230: --------------------------------------- Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/1910#discussion_r60207331 --- Diff: flink-streaming-connectors/flink-connector-twitter/pom.xml --- @@ -35,6 +35,11 @@ under the License. <packaging>jar</packaging> + <properties> + <hbc-core.version>2.2.0</hbc-core.version> --- End diff -- how is this change related to the Kinesis connector? > Kinesis streaming producer > -------------------------- > > Key: FLINK-3230 > URL: https://issues.apache.org/jira/browse/FLINK-3230 > Project: Flink > Issue Type: Sub-task > Components: Streaming Connectors > Reporter: Tzu-Li (Gordon) Tai > Assignee: Robert Metzger > > Add a FlinkKinesisProducer for the Flink Kinesis streaming connector. We will > be using AWS SDK implementation for code consistency with the > FlinkKinesisConsumer. > The features of FlinkKinesisProducer is rather straightforward: > 1. Partition put records based on partition key. > 2. Configurable put mode: Bulk put for higher throughput vs. sequential > single record puts. Size of bulk should also be configurable. > 3. For bulk put, user can also choose to enforce strict ordering of the > result with the tradeoff of higher put latency. Ref: > https://brandur.org/kinesis-order -- This message was sent by Atlassian JIRA (v6.3.4#6332)