|
Change Parameter Type consumer : KafkaConsumer<byte[],byte[]> to consumer : KafkaConsumer<?,?> in method protected assignPartitionsToConsumer(consumer KafkaConsumer<?,?>, topicPartitions List<TopicPartition>) : void in class org.apache.flink.streaming.connectors.kafka.internal.Kafka09Fetcher |
From |
To |
|
Change Parameter Type consumer : KafkaConsumer<byte[],byte[]> to consumer : KafkaConsumer<?,?> in method protected assignPartitionsToConsumer(consumer KafkaConsumer<?,?>, topicPartitions List<TopicPartition>) : void in class org.apache.flink.streaming.connectors.kafka.internal.Kafka010Fetcher |
From |
To |
|
Change Parameter Type ktp : KafkaTopicPartitionState to ktp : KafkaTopicPartitionState<?> in method public OffsetGauge(ktp KafkaTopicPartitionState<?>, gaugeType OffsetGaugeType) in class org.apache.flink.streaming.connectors.kafka.internals.AbstractFetcher.OffsetGauge |
From |
To |
|
Change Parameter Type consumerRecord : ConsumerRecord to consumerRecord : ConsumerRecord<?,?> in method protected emitRecord(record T, partition KafkaTopicPartitionState<TopicPartition>, offset long, consumerRecord ConsumerRecord<?,?>) : void in class org.apache.flink.streaming.connectors.kafka.internal.Kafka010Fetcher |
From |
To |
|
Change Parameter Type consumerRecord : ConsumerRecord to consumerRecord : ConsumerRecord<?,?> in method protected emitRecord(record T, partition KafkaTopicPartitionState<TopicPartition>, offset long, consumerRecord ConsumerRecord<?,?>) : void in class org.apache.flink.streaming.connectors.kafka.internal.Kafka09Fetcher |
From |
To |