Hello,
I've noticed the usage of "PublicEvolving" in some Flink classes described
as follows
/**
* Annotation to mark classes and methods for public use, but with evolving
interfaces.
*
* Classes and methods with this annotation are intended for public use
and have stable behavior.
* However,
r/flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/internals/publisher/RecordBatch.java#L93
>
>
>
> On Thu, 14 Apr 2022, 23:56 Blake Wilson, wrote:
>
> > Thanks for offering to review, Danny.
> >
> > Thank
your list will be sent to the same
> > shard. If the sender implements grouping of records by partition key,
> then
> > care needs to be taken during shard scaling.
> >
> > Thanks,
> >
> > [1]
> >
> https://docs.aws.amazon.com/streams/latest/dev/kinesis-kpl
Hello, I recently submitted a pull request to support the Collector API for
the Kinesis Streams Connector.
The ability to use this API would save a great deal of shuttling bytes
around in multiple Flink programs I've worked on. This is because to
construct a stream of the desired type without Coll
