|
Move Class org.apache.kafka.copied.common.network.Receive moved to org.apache.flink.kafka_backport.common.network.Receive |
From |
To |
|
Move Class org.apache.kafka.copied.common.errors.NotLeaderForPartitionException moved to org.apache.flink.kafka_backport.common.errors.NotLeaderForPartitionException |
From |
To |
|
Move Class org.apache.kafka.copied.clients.consumer.internals.Heartbeat moved to org.apache.flink.kafka_backport.clients.consumer.internals.Heartbeat |
From |
To |
|
Move Class org.apache.kafka.copied.common.metrics.JmxReporter moved to org.apache.flink.kafka_backport.common.metrics.JmxReporter |
From |
To |
|
Move Class org.apache.kafka.copied.clients.consumer.internals.RequestFutureListener moved to org.apache.flink.kafka_backport.clients.consumer.internals.RequestFutureListener |
From |
To |
|
Move Class org.apache.kafka.copied.common.record.KafkaLZ4BlockOutputStream moved to org.apache.flink.kafka_backport.common.record.KafkaLZ4BlockOutputStream |
From |
To |
|
Move Class org.apache.kafka.copied.common.network.Selectable moved to org.apache.flink.kafka_backport.common.network.Selectable |
From |
To |
|
Move Class org.apache.kafka.copied.clients.NetworkClient moved to org.apache.flink.kafka_backport.clients.NetworkClient |
From |
To |
|
Move Class org.apache.kafka.copied.common.requests.HeartbeatRequest moved to org.apache.flink.kafka_backport.common.requests.HeartbeatRequest |
From |
To |
|
Move Class org.apache.kafka.copied.common.record.ByteBufferOutputStream moved to org.apache.flink.kafka_backport.common.record.ByteBufferOutputStream |
From |
To |
|
Move Class org.apache.kafka.copied.common.protocol.types.Schema moved to org.apache.flink.kafka_backport.common.protocol.types.Schema |
From |
To |
|
Move Class org.apache.kafka.copied.common.utils.CopyOnWriteMap moved to org.apache.flink.kafka_backport.common.utils.CopyOnWriteMap |
From |
To |
|
Move Class org.apache.kafka.copied.common.serialization.Deserializer moved to org.apache.flink.kafka_backport.common.serialization.Deserializer |
From |
To |
|
Move Class org.apache.kafka.copied.common.protocol.types.Type moved to org.apache.flink.kafka_backport.common.protocol.types.Type |
From |
To |
|
Move Class org.apache.kafka.copied.common.metrics.stats.Total moved to org.apache.flink.kafka_backport.common.metrics.stats.Total |
From |
To |
|
Move Class org.apache.kafka.copied.common.requests.MetadataRequest moved to org.apache.flink.kafka_backport.common.requests.MetadataRequest |
From |
To |
|
Move Class org.apache.kafka.copied.common.errors.IllegalGenerationException moved to org.apache.flink.kafka_backport.common.errors.IllegalGenerationException |
From |
To |
|
Move Class org.apache.kafka.copied.common.serialization.IntegerSerializer moved to org.apache.flink.kafka_backport.common.serialization.IntegerSerializer |
From |
To |
|
Move Class org.apache.kafka.copied.common.network.MultiSend moved to org.apache.flink.kafka_backport.common.network.MultiSend |
From |
To |
|
Move Class org.apache.kafka.copied.clients.consumer.internals.DelayedTaskQueue moved to org.apache.flink.kafka_backport.clients.consumer.internals.DelayedTaskQueue |
From |
To |
|
Move Class org.apache.kafka.copied.clients.ClientRequest moved to org.apache.flink.kafka_backport.clients.ClientRequest |
From |
To |
|
Move Class org.apache.kafka.copied.clients.consumer.ConsumerConfig moved to org.apache.flink.kafka_backport.clients.consumer.ConsumerConfig |
From |
To |
|
Move Class org.apache.kafka.copied.common.errors.RecordBatchTooLargeException moved to org.apache.flink.kafka_backport.common.errors.RecordBatchTooLargeException |
From |
To |
|
Move Class org.apache.kafka.copied.common.errors.SerializationException moved to org.apache.flink.kafka_backport.common.errors.SerializationException |
From |
To |
|
Move Class org.apache.kafka.copied.common.record.LogEntry moved to org.apache.flink.kafka_backport.common.record.LogEntry |
From |
To |
|
Move Class org.apache.kafka.copied.clients.consumer.internals.RequestFuture moved to org.apache.flink.kafka_backport.clients.consumer.internals.RequestFuture |
From |
To |
|
Move Class org.apache.kafka.copied.common.requests.ResponseHeader moved to org.apache.flink.kafka_backport.common.requests.ResponseHeader |
From |
To |
|
Move Class org.apache.kafka.copied.clients.CommonClientConfigs moved to org.apache.flink.kafka_backport.clients.CommonClientConfigs |
From |
To |
|
Move Class org.apache.kafka.copied.clients.consumer.internals.Fetcher moved to org.apache.flink.kafka_backport.clients.consumer.internals.Fetcher |
From |
To |
|
Move Class org.apache.kafka.copied.clients.KafkaClient moved to org.apache.flink.kafka_backport.clients.KafkaClient |
From |
To |
|
Move Class org.apache.kafka.copied.common.errors.InvalidMetadataException moved to org.apache.flink.kafka_backport.common.errors.InvalidMetadataException |
From |
To |
|
Move Class org.apache.kafka.copied.common.errors.OffsetLoadInProgressException moved to org.apache.flink.kafka_backport.common.errors.OffsetLoadInProgressException |
From |
To |
|
Move Class org.apache.kafka.copied.common.network.ByteBufferSend moved to org.apache.flink.kafka_backport.common.network.ByteBufferSend |
From |
To |
|
Move Class org.apache.kafka.copied.common.record.MemoryRecords moved to org.apache.flink.kafka_backport.common.record.MemoryRecords |
From |
To |
|
Move Class org.apache.kafka.copied.common.requests.ProduceResponse moved to org.apache.flink.kafka_backport.common.requests.ProduceResponse |
From |
To |
|
Move Class org.apache.kafka.copied.common.protocol.ProtoUtils moved to org.apache.flink.kafka_backport.common.protocol.ProtoUtils |
From |
To |
|
Move Class org.apache.kafka.copied.clients.consumer.internals.ConsumerNetworkClient moved to org.apache.flink.kafka_backport.clients.consumer.internals.ConsumerNetworkClient |
From |
To |
|
Move Class org.apache.kafka.copied.common.utils.Time moved to org.apache.flink.kafka_backport.common.utils.Time |
From |
To |
|
Move Class org.apache.kafka.copied.clients.consumer.ConsumerRecord moved to org.apache.flink.kafka_backport.clients.consumer.ConsumerRecord |
From |
To |
|
Move Class org.apache.kafka.copied.clients.ClientUtils moved to org.apache.flink.kafka_backport.clients.ClientUtils |
From |
To |
|
Move Class org.apache.kafka.copied.common.requests.ListOffsetResponse moved to org.apache.flink.kafka_backport.common.requests.ListOffsetResponse |
From |
To |
|
Move Class org.apache.kafka.copied.common.errors.NetworkException moved to org.apache.flink.kafka_backport.common.errors.NetworkException |
From |
To |
|
Move Class org.apache.kafka.copied.common.errors.NotCoordinatorForConsumerException moved to org.apache.flink.kafka_backport.common.errors.NotCoordinatorForConsumerException |
From |
To |
|
Move Class org.apache.kafka.copied.common.protocol.ApiKeys moved to org.apache.flink.kafka_backport.common.protocol.ApiKeys |
From |
To |
|
Move Class org.apache.kafka.copied.common.record.InvalidRecordException moved to org.apache.flink.kafka_backport.common.record.InvalidRecordException |
From |
To |
|
Move Class org.apache.kafka.copied.clients.RequestCompletionHandler moved to org.apache.flink.kafka_backport.clients.RequestCompletionHandler |
From |
To |
|
Move Class org.apache.kafka.copied.clients.consumer.ConsumerRebalanceCallback moved to org.apache.flink.kafka_backport.clients.consumer.ConsumerRebalanceCallback |
From |
To |
|
Move Class org.apache.kafka.copied.common.Node moved to org.apache.flink.kafka_backport.common.Node |
From |
To |
|
Move Class org.apache.kafka.copied.common.protocol.Protocol moved to org.apache.flink.kafka_backport.common.protocol.Protocol |
From |
To |
|
Move Class org.apache.kafka.copied.common.metrics.stats.Rate moved to org.apache.flink.kafka_backport.common.metrics.stats.Rate |
From |
To |
|
Move Class org.apache.kafka.copied.common.metrics.MeasurableStat moved to org.apache.flink.kafka_backport.common.metrics.MeasurableStat |
From |
To |
|
Move Class org.apache.kafka.copied.common.requests.ConsumerMetadataResponse moved to org.apache.flink.kafka_backport.common.requests.ConsumerMetadataResponse |
From |
To |
|
Move Class org.apache.kafka.copied.common.network.NetworkReceive moved to org.apache.flink.kafka_backport.common.network.NetworkReceive |
From |
To |
|
Move Class org.apache.kafka.copied.common.Metric moved to org.apache.flink.kafka_backport.common.Metric |
From |
To |
|
Move Class org.apache.kafka.copied.common.network.InvalidReceiveException moved to org.apache.flink.kafka_backport.common.network.InvalidReceiveException |
From |
To |
|
Move Class org.apache.kafka.copied.common.requests.OffsetCommitResponse moved to org.apache.flink.kafka_backport.common.requests.OffsetCommitResponse |
From |
To |
|
Move Class org.apache.kafka.copied.common.metrics.Measurable moved to org.apache.flink.kafka_backport.common.metrics.Measurable |
From |
To |
|
Move Class org.apache.kafka.copied.common.errors.LeaderNotAvailableException moved to org.apache.flink.kafka_backport.common.errors.LeaderNotAvailableException |
From |
To |
|
Move Class org.apache.kafka.copied.common.metrics.stats.Count moved to org.apache.flink.kafka_backport.common.metrics.stats.Count |
From |
To |
|
Move Class org.apache.kafka.copied.clients.consumer.ConsumerWakeupException moved to org.apache.flink.kafka_backport.clients.consumer.ConsumerWakeupException |
From |
To |
|
Move Class org.apache.kafka.copied.common.requests.JoinGroupRequest moved to org.apache.flink.kafka_backport.common.requests.JoinGroupRequest |
From |
To |
|
Move Class org.apache.kafka.copied.common.requests.ConsumerMetadataRequest moved to org.apache.flink.kafka_backport.common.requests.ConsumerMetadataRequest |
From |
To |
|
Move Class org.apache.kafka.copied.clients.InFlightRequests moved to org.apache.flink.kafka_backport.clients.InFlightRequests |
From |
To |
|
Move Class org.apache.kafka.copied.common.errors.UnknownTopicOrPartitionException moved to org.apache.flink.kafka_backport.common.errors.UnknownTopicOrPartitionException |
From |
To |
|
Move Class org.apache.kafka.copied.common.requests.AbstractRequest moved to org.apache.flink.kafka_backport.common.requests.AbstractRequest |
From |
To |
|
Move Class org.apache.kafka.copied.clients.consumer.ConsumerCommitCallback moved to org.apache.flink.kafka_backport.clients.consumer.ConsumerCommitCallback |
From |
To |
|
Move Class org.apache.kafka.copied.common.requests.ResponseSend moved to org.apache.flink.kafka_backport.common.requests.ResponseSend |
From |
To |
|
Move Class org.apache.kafka.copied.common.protocol.types.Struct moved to org.apache.flink.kafka_backport.common.protocol.types.Struct |
From |
To |
|
Move Class org.apache.kafka.copied.common.record.Record moved to org.apache.flink.kafka_backport.common.record.Record |
From |
To |
|
Move Class org.apache.kafka.copied.common.requests.FetchResponse moved to org.apache.flink.kafka_backport.common.requests.FetchResponse |
From |
To |
|
Move Class org.apache.kafka.copied.common.protocol.SecurityProtocol moved to org.apache.flink.kafka_backport.common.protocol.SecurityProtocol |
From |
To |
|
Move Class org.apache.kafka.copied.common.metrics.CompoundStat moved to org.apache.flink.kafka_backport.common.metrics.CompoundStat |
From |
To |
|
Move Class org.apache.kafka.copied.common.metrics.stats.Max moved to org.apache.flink.kafka_backport.common.metrics.stats.Max |
From |
To |
|
Move Class org.apache.kafka.copied.clients.consumer.Consumer moved to org.apache.flink.kafka_backport.clients.consumer.Consumer |
From |
To |
|
Move Class org.apache.kafka.copied.common.protocol.types.SchemaException moved to org.apache.flink.kafka_backport.common.protocol.types.SchemaException |
From |
To |
|
Move Class org.apache.kafka.copied.common.utils.Utils moved to org.apache.flink.kafka_backport.common.utils.Utils |
From |
To |
|
Move Class org.apache.kafka.copied.common.network.ByteBufferReceive moved to org.apache.flink.kafka_backport.common.network.ByteBufferReceive |
From |
To |
|
Move Class org.apache.kafka.copied.common.requests.MetadataResponse moved to org.apache.flink.kafka_backport.common.requests.MetadataResponse |
From |
To |
|
Move Class org.apache.kafka.copied.common.Cluster moved to org.apache.flink.kafka_backport.common.Cluster |
From |
To |
|
Move Class org.apache.kafka.copied.common.metrics.stats.Min moved to org.apache.flink.kafka_backport.common.metrics.stats.Min |
From |
To |
|
Move Class org.apache.kafka.copied.common.KafkaException moved to org.apache.flink.kafka_backport.common.KafkaException |
From |
To |
|
Move Class org.apache.kafka.copied.common.metrics.stats.SampledStat moved to org.apache.flink.kafka_backport.common.metrics.stats.SampledStat |
From |
To |
|
Move Class org.apache.kafka.copied.common.serialization.ByteArraySerializer moved to org.apache.flink.kafka_backport.common.serialization.ByteArraySerializer |
From |
To |
|
Move Class org.apache.kafka.copied.clients.consumer.ConsumerRecords moved to org.apache.flink.kafka_backport.clients.consumer.ConsumerRecords |
From |
To |
|
Move Class org.apache.kafka.copied.common.errors.RecordTooLargeException moved to org.apache.flink.kafka_backport.common.errors.RecordTooLargeException |
From |
To |
|
Move Class org.apache.kafka.copied.common.requests.ListOffsetRequest moved to org.apache.flink.kafka_backport.common.requests.ListOffsetRequest |
From |
To |
|
Move Class org.apache.kafka.copied.clients.consumer.internals.NoOpConsumerRebalanceCallback moved to org.apache.flink.kafka_backport.clients.consumer.internals.NoOpConsumerRebalanceCallback |
From |
To |
|
Move Class org.apache.kafka.copied.common.network.NetworkSend moved to org.apache.flink.kafka_backport.common.network.NetworkSend |
From |
To |
|
Move Class org.apache.kafka.copied.common.metrics.MetricConfig moved to org.apache.flink.kafka_backport.common.metrics.MetricConfig |
From |
To |
|
Move Class org.apache.kafka.copied.common.record.Compressor moved to org.apache.flink.kafka_backport.common.record.Compressor |
From |
To |
|
Move Class org.apache.kafka.copied.common.errors.NotEnoughReplicasException moved to org.apache.flink.kafka_backport.common.errors.NotEnoughReplicasException |
From |
To |
|
Move Class org.apache.kafka.copied.clients.consumer.internals.DelayedTask moved to org.apache.flink.kafka_backport.clients.consumer.internals.DelayedTask |
From |
To |
|
Move Class org.apache.kafka.copied.common.errors.UnknownServerException moved to org.apache.flink.kafka_backport.common.errors.UnknownServerException |
From |
To |
|
Move Class org.apache.kafka.copied.clients.Metadata moved to org.apache.flink.kafka_backport.clients.Metadata |
From |
To |
|
Move Class org.apache.kafka.copied.common.errors.CorruptRecordException moved to org.apache.flink.kafka_backport.common.errors.CorruptRecordException |
From |
To |
|
Move Class org.apache.kafka.copied.common.metrics.stats.Percentiles moved to org.apache.flink.kafka_backport.common.metrics.stats.Percentiles |
From |
To |
|
Move Class org.apache.kafka.copied.common.requests.OffsetFetchRequest moved to org.apache.flink.kafka_backport.common.requests.OffsetFetchRequest |
From |
To |
|
Move Class org.apache.kafka.copied.common.metrics.MetricsReporter moved to org.apache.flink.kafka_backport.common.metrics.MetricsReporter |
From |
To |
|
Move Class org.apache.kafka.copied.common.record.Records moved to org.apache.flink.kafka_backport.common.record.Records |
From |
To |
|
Move Class org.apache.kafka.copied.common.protocol.types.ArrayOf moved to org.apache.flink.kafka_backport.common.protocol.types.ArrayOf |
From |
To |
|
Move Class org.apache.kafka.copied.common.requests.OffsetFetchResponse moved to org.apache.flink.kafka_backport.common.requests.OffsetFetchResponse |
From |
To |
|
Move Class org.apache.kafka.copied.clients.consumer.OffsetResetStrategy moved to org.apache.flink.kafka_backport.clients.consumer.OffsetResetStrategy |
From |
To |
|
Move Class org.apache.kafka.copied.common.requests.OffsetCommitRequest moved to org.apache.flink.kafka_backport.common.requests.OffsetCommitRequest |
From |
To |
|
Move Class org.apache.kafka.copied.common.network.Send moved to org.apache.flink.kafka_backport.common.network.Send |
From |
To |
|
Move Class org.apache.kafka.copied.clients.consumer.MockConsumer moved to org.apache.flink.kafka_backport.clients.consumer.MockConsumer |
From |
To |
|
Move Class org.apache.kafka.copied.common.utils.KafkaThread moved to org.apache.flink.kafka_backport.common.utils.KafkaThread |
From |
To |
|
Move Class org.apache.kafka.copied.clients.consumer.KafkaConsumer moved to org.apache.flink.kafka_backport.clients.consumer.KafkaConsumer |
From |
To |
|
Move Class org.apache.kafka.copied.common.utils.SystemTime moved to org.apache.flink.kafka_backport.common.utils.SystemTime |
From |
To |
|
Move Class org.apache.kafka.copied.common.config.ConfigDef moved to org.apache.flink.kafka_backport.common.config.ConfigDef |
From |
To |
|
Move Class org.apache.kafka.copied.common.metrics.KafkaMetric moved to org.apache.flink.kafka_backport.common.metrics.KafkaMetric |
From |
To |
|
Move Class org.apache.kafka.copied.common.utils.Crc32 moved to org.apache.flink.kafka_backport.common.utils.Crc32 |
From |
To |
|
Move Class org.apache.kafka.copied.common.errors.InvalidTopicException moved to org.apache.flink.kafka_backport.common.errors.InvalidTopicException |
From |
To |
|
Move Class org.apache.kafka.copied.common.metrics.QuotaViolationException moved to org.apache.flink.kafka_backport.common.metrics.QuotaViolationException |
From |
To |
|
Move Class org.apache.kafka.copied.common.metrics.stats.Percentile moved to org.apache.flink.kafka_backport.common.metrics.stats.Percentile |
From |
To |
|
Move Class org.apache.kafka.copied.clients.ClientResponse moved to org.apache.flink.kafka_backport.clients.ClientResponse |
From |
To |
|
Move Class org.apache.kafka.copied.common.errors.InterruptException moved to org.apache.flink.kafka_backport.common.errors.InterruptException |
From |
To |
|
Move Class org.apache.kafka.copied.common.errors.DisconnectException moved to org.apache.flink.kafka_backport.common.errors.DisconnectException |
From |
To |
|
Move Class org.apache.kafka.copied.common.serialization.IntegerDeserializer moved to org.apache.flink.kafka_backport.common.serialization.IntegerDeserializer |
From |
To |
|
Move Class org.apache.kafka.copied.common.protocol.Errors moved to org.apache.flink.kafka_backport.common.protocol.Errors |
From |
To |
|
Move Class org.apache.kafka.copied.common.requests.AbstractRequestResponse moved to org.apache.flink.kafka_backport.common.requests.AbstractRequestResponse |
From |
To |
|
Move Class org.apache.kafka.copied.clients.consumer.internals.SendFailedException moved to org.apache.flink.kafka_backport.clients.consumer.internals.SendFailedException |
From |
To |
|
Move Class org.apache.kafka.copied.common.config.ConfigException moved to org.apache.flink.kafka_backport.common.config.ConfigException |
From |
To |
|
Move Class org.apache.kafka.copied.common.utils.CollectionUtils moved to org.apache.flink.kafka_backport.common.utils.CollectionUtils |
From |
To |
|
Move Class org.apache.kafka.copied.common.Configurable moved to org.apache.flink.kafka_backport.common.Configurable |
From |
To |
|
Move Class org.apache.kafka.copied.clients.consumer.internals.Coordinator moved to org.apache.flink.kafka_backport.clients.consumer.internals.Coordinator |
From |
To |
|
Move Class org.apache.kafka.copied.common.errors.UnknownConsumerIdException moved to org.apache.flink.kafka_backport.common.errors.UnknownConsumerIdException |
From |
To |
|
Move Class org.apache.kafka.copied.common.record.KafkaLZ4BlockInputStream moved to org.apache.flink.kafka_backport.common.record.KafkaLZ4BlockInputStream |
From |
To |
|
Move Class org.apache.kafka.copied.common.errors.InvalidRequiredAcksException moved to org.apache.flink.kafka_backport.common.errors.InvalidRequiredAcksException |
From |
To |
|
Move Class org.apache.kafka.copied.common.requests.RequestHeader moved to org.apache.flink.kafka_backport.common.requests.RequestHeader |
From |
To |
|
Move Class org.apache.kafka.copied.common.record.ByteBufferInputStream moved to org.apache.flink.kafka_backport.common.record.ByteBufferInputStream |
From |
To |
|
Move Class org.apache.kafka.copied.common.config.AbstractConfig moved to org.apache.flink.kafka_backport.common.config.AbstractConfig |
From |
To |
|
Move Class org.apache.kafka.copied.common.PartitionInfo moved to org.apache.flink.kafka_backport.common.PartitionInfo |
From |
To |
|
Move Class org.apache.kafka.copied.common.serialization.StringDeserializer moved to org.apache.flink.kafka_backport.common.serialization.StringDeserializer |
From |
To |
|
Move Class org.apache.kafka.copied.common.TopicPartition moved to org.apache.flink.kafka_backport.common.TopicPartition |
From |
To |
|
Move Class org.apache.kafka.copied.common.requests.HeartbeatResponse moved to org.apache.flink.kafka_backport.common.requests.HeartbeatResponse |
From |
To |
|
Move Class org.apache.kafka.copied.common.errors.ApiException moved to org.apache.flink.kafka_backport.common.errors.ApiException |
From |
To |
|
Move Class org.apache.kafka.copied.common.metrics.Metrics moved to org.apache.flink.kafka_backport.common.metrics.Metrics |
From |
To |
|
Move Class org.apache.kafka.copied.common.errors.RetriableException moved to org.apache.flink.kafka_backport.common.errors.RetriableException |
From |
To |
|
Move Class org.apache.kafka.copied.clients.ConnectionState moved to org.apache.flink.kafka_backport.clients.ConnectionState |
From |
To |
|
Move Class org.apache.kafka.copied.clients.consumer.internals.RequestFutureAdapter moved to org.apache.flink.kafka_backport.clients.consumer.internals.RequestFutureAdapter |
From |
To |
|
Move Class org.apache.kafka.copied.common.metrics.Stat moved to org.apache.flink.kafka_backport.common.metrics.Stat |
From |
To |
|
Move Class org.apache.kafka.copied.common.metrics.Quota moved to org.apache.flink.kafka_backport.common.metrics.Quota |
From |
To |
|
Move Class org.apache.kafka.copied.common.network.Selector moved to org.apache.flink.kafka_backport.common.network.Selector |
From |
To |
|
Move Class org.apache.kafka.copied.common.metrics.stats.Avg moved to org.apache.flink.kafka_backport.common.metrics.stats.Avg |
From |
To |
|
Move Class org.apache.kafka.copied.common.errors.TimeoutException moved to org.apache.flink.kafka_backport.common.errors.TimeoutException |
From |
To |
|
Move Class org.apache.kafka.copied.common.serialization.StringSerializer moved to org.apache.flink.kafka_backport.common.serialization.StringSerializer |
From |
To |
|
Move Class org.apache.kafka.copied.common.utils.AbstractIterator moved to org.apache.flink.kafka_backport.common.utils.AbstractIterator |
From |
To |
|
Move Class org.apache.kafka.copied.common.errors.OffsetOutOfRangeException moved to org.apache.flink.kafka_backport.common.errors.OffsetOutOfRangeException |
From |
To |
|
Move Class org.apache.kafka.copied.common.metrics.Sensor moved to org.apache.flink.kafka_backport.common.metrics.Sensor |
From |
To |
|
Move Class org.apache.kafka.copied.common.requests.FetchRequest moved to org.apache.flink.kafka_backport.common.requests.FetchRequest |
From |
To |
|
Move Class org.apache.kafka.copied.clients.consumer.internals.NoAvailableBrokersException moved to org.apache.flink.kafka_backport.clients.consumer.internals.NoAvailableBrokersException |
From |
To |
|
Move Class org.apache.kafka.copied.common.serialization.Serializer moved to org.apache.flink.kafka_backport.common.serialization.Serializer |
From |
To |
|
Move Class org.apache.kafka.copied.clients.consumer.CommitType moved to org.apache.flink.kafka_backport.clients.consumer.CommitType |
From |
To |
|
Move Class org.apache.kafka.copied.common.requests.JoinGroupResponse moved to org.apache.flink.kafka_backport.common.requests.JoinGroupResponse |
From |
To |
|
Move Class org.apache.kafka.copied.common.requests.RequestSend moved to org.apache.flink.kafka_backport.common.requests.RequestSend |
From |
To |
|
Move Class org.apache.kafka.copied.clients.consumer.NoOffsetForPartitionException moved to org.apache.flink.kafka_backport.clients.consumer.NoOffsetForPartitionException |
From |
To |
|
Move Class org.apache.kafka.copied.common.errors.OffsetMetadataTooLarge moved to org.apache.flink.kafka_backport.common.errors.OffsetMetadataTooLarge |
From |
To |
|
Move Class org.apache.kafka.copied.clients.ClusterConnectionStates moved to org.apache.flink.kafka_backport.clients.ClusterConnectionStates |
From |
To |
|
Move Class org.apache.kafka.copied.common.serialization.ByteArrayDeserializer moved to org.apache.flink.kafka_backport.common.serialization.ByteArrayDeserializer |
From |
To |
|
Move Class org.apache.kafka.copied.common.record.CompressionType moved to org.apache.flink.kafka_backport.common.record.CompressionType |
From |
To |
|
Move Class org.apache.kafka.copied.common.metrics.stats.Histogram moved to org.apache.flink.kafka_backport.common.metrics.stats.Histogram |
From |
To |
|
Move Class org.apache.kafka.copied.common.requests.ProduceRequest moved to org.apache.flink.kafka_backport.common.requests.ProduceRequest |
From |
To |
|
Move Class org.apache.kafka.copied.common.protocol.types.Field moved to org.apache.flink.kafka_backport.common.protocol.types.Field |
From |
To |
|
Move Class org.apache.kafka.copied.common.errors.NotEnoughReplicasAfterAppendException moved to org.apache.flink.kafka_backport.common.errors.NotEnoughReplicasAfterAppendException |
From |
To |
|
Move Class org.apache.kafka.copied.clients.consumer.internals.StaleMetadataException moved to org.apache.flink.kafka_backport.clients.consumer.internals.StaleMetadataException |
From |
To |
|
Move Class org.apache.kafka.copied.common.MetricName moved to org.apache.flink.kafka_backport.common.MetricName |
From |
To |
|
Move Class org.apache.kafka.copied.clients.consumer.internals.SubscriptionState moved to org.apache.flink.kafka_backport.clients.consumer.internals.SubscriptionState |
From |
To |
|
Move Class org.apache.kafka.copied.common.errors.ConsumerCoordinatorNotAvailableException moved to org.apache.flink.kafka_backport.common.errors.ConsumerCoordinatorNotAvailableException |
From |
To |