org.apache.flink.connector.kinesis.sink
org.apache.flink.connector.kinesis.source
org.apache.flink.connector.kinesis.source.config
org.apache.flink.connector.kinesis.source.enumerator
org.apache.flink.connector.kinesis.source.enumerator.assigner
org.apache.flink.connector.kinesis.source.exception
org.apache.flink.connector.kinesis.source.proxy
org.apache.flink.connector.kinesis.source.reader
org.apache.flink.connector.kinesis.source.serialization
org.apache.flink.connector.kinesis.source.split
org.apache.flink.connector.kinesis.table
org.apache.flink.connector.kinesis.table.util