|
Move Class org.apache.flink.streaming.connectors.internals.ZookeeperOffsetHandlerTest moved to org.apache.flink.streaming.connectors.kafka.internals.ZookeeperOffsetHandlerTest |
From |
To |
|
Move Class org.apache.flink.streaming.connectors.KafkaLocalSystemTime moved to org.apache.flink.streaming.connectors.kafka.KafkaLocalSystemTime |
From |
To |
|
Move Class org.apache.flink.streaming.connectors.testutils.ThrottledMapper moved to org.apache.flink.streaming.connectors.kafka.testutils.ThrottledMapper |
From |
To |
|
Move Class org.apache.flink.streaming.connectors.KafkaConsumerTestBase moved to org.apache.flink.streaming.connectors.kafka.KafkaConsumerTestBase |
From |
To |
|
Move Class org.apache.flink.streaming.connectors.PartitionerWrapper moved to org.apache.flink.streaming.connectors.kafka.internals.PartitionerWrapper |
From |
To |
|
Move Class org.apache.flink.streaming.connectors.testutils.DataGenerators moved to org.apache.flink.streaming.connectors.kafka.testutils.DataGenerators |
From |
To |
|
Move Class org.apache.flink.streaming.connectors.testutils.Tuple2Partitioner moved to org.apache.flink.streaming.connectors.kafka.testutils.Tuple2Partitioner |
From |
To |
|
Move Class org.apache.flink.streaming.connectors.internals.OffsetHandler moved to org.apache.flink.streaming.connectors.kafka.internals.OffsetHandler |
From |
To |
|
Move Class org.apache.flink.streaming.connectors.internals.ZooKeeperStringSerializer moved to org.apache.flink.streaming.connectors.kafka.internals.ZooKeeperStringSerializer |
From |
To |
|
Move Class org.apache.flink.streaming.connectors.internals.Fetcher moved to org.apache.flink.streaming.connectors.kafka.internals.Fetcher |
From |
To |
|
Move Class org.apache.flink.streaming.connectors.testutils.ValidatingExactlyOnceSink moved to org.apache.flink.streaming.connectors.kafka.testutils.ValidatingExactlyOnceSink |
From |
To |
|
Move Class org.apache.flink.streaming.connectors.testutils.SuccessException moved to org.apache.flink.streaming.connectors.kafka.testutils.SuccessException |
From |
To |
|
Move Class org.apache.flink.streaming.connectors.FlinkKafkaConsumer082 moved to org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumer082 |
From |
To |
|
Move Class org.apache.flink.streaming.connectors.testutils.DiscardingSink moved to org.apache.flink.streaming.connectors.kafka.testutils.DiscardingSink |
From |
To |
|
Move Class org.apache.flink.streaming.connectors.testutils.JobManagerCommunicationUtils moved to org.apache.flink.streaming.connectors.kafka.testutils.JobManagerCommunicationUtils |
From |
To |
|
Move Class org.apache.flink.streaming.connectors.KafkaConsumerTest moved to org.apache.flink.streaming.connectors.kafka.KafkaConsumerTest |
From |
To |
|
Move Class org.apache.flink.streaming.connectors.internals.LegacyFetcher moved to org.apache.flink.streaming.connectors.kafka.internals.LegacyFetcher |
From |
To |
|
Move Class org.apache.flink.streaming.connectors.testutils.MockRuntimeContext moved to org.apache.flink.streaming.connectors.kafka.testutils.MockRuntimeContext |
From |
To |
|
Move Class org.apache.flink.streaming.connectors.KafkaConsumerPartitionAssignmentTest moved to org.apache.flink.streaming.connectors.kafka.KafkaConsumerPartitionAssignmentTest |
From |
To |
|
Move Class org.apache.flink.streaming.connectors.SerializableKafkaPartitioner moved to org.apache.flink.streaming.connectors.kafka.SerializableKafkaPartitioner |
From |
To |
|
Move Class org.apache.flink.streaming.connectors.internals.ZookeeperOffsetHandler moved to org.apache.flink.streaming.connectors.kafka.internals.ZookeeperOffsetHandler |
From |
To |
|
Move Class org.apache.flink.streaming.connectors.KafkaSink moved to org.apache.flink.streaming.connectors.kafka.KafkaSink |
From |
To |
|
Move Class org.apache.flink.streaming.connectors.KafkaITCase moved to org.apache.flink.streaming.connectors.kafka.KafkaITCase |
From |
To |
|
Move Class org.apache.flink.streaming.connectors.FlinkKafkaConsumer081 moved to org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumer081 |
From |
To |
|
Move Class org.apache.flink.streaming.connectors.FlinkKafkaConsumer moved to org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumer |
From |
To |
|
Move Class org.apache.flink.streaming.connectors.KafkaTestBase moved to org.apache.flink.streaming.connectors.kafka.KafkaTestBase |
From |
To |
|
Move Class org.apache.flink.streaming.connectors.testutils.PartitionValidatingMapper moved to org.apache.flink.streaming.connectors.kafka.testutils.PartitionValidatingMapper |
From |
To |
|
Move Class org.apache.flink.streaming.connectors.testutils.FailingIdentityMapper moved to org.apache.flink.streaming.connectors.kafka.testutils.FailingIdentityMapper |
From |
To |
|
Move Class org.apache.flink.streaming.connectors.KafkaProducerITCase moved to org.apache.flink.streaming.connectors.kafka.KafkaProducerITCase |
From |
To |